| /* |
| * The contents of this file are subject to the terms |
| * of the Common Development and Distribution License |
| * (the License). You may not use this file except in |
| * compliance with the License. |
| * |
| * You can obtain a copy of the license at |
| * https://glassfish.dev.java.net/public/CDDLv1.0.html or |
| * glassfish/bootstrap/legal/CDDLv1.0.txt. |
| * See the License for the specific language governing |
| * permissions and limitations under the License. |
| * |
| * When distributing Covered Code, include this CDDL |
| * Header Notice in each file and include the License file |
| * at glassfish/bootstrap/legal/CDDLv1.0.txt. |
| * If applicable, add the following below the CDDL Header, |
| * with the fields enclosed by brackets [] replaced by |
| * you own identifying information: |
| * "Portions Copyrighted [year] [name of copyright owner]" |
| * |
| * Copyright 2006 Sun Microsystems, Inc. All rights reserved. |
| */ |
| |
| package javax.jms; |
| |
| import java.io.Serializable; |
| |
| /** <P>A <CODE>Session</CODE> object is a single-threaded context for producing and consuming |
| * messages. Although it may allocate provider resources outside the Java |
| * virtual machine (JVM), it is considered a lightweight JMS object. |
| * |
| * <P>A session serves several purposes: |
| * |
| * <UL> |
| * <LI>It is a factory for its message producers and consumers. |
| * <LI>It supplies provider-optimized message factories. |
| * <LI>It is a factory for <CODE>TemporaryTopics</CODE> and |
| * <CODE>TemporaryQueues</CODE>. |
| * <LI> It provides a way to create <CODE>Queue</CODE> or <CODE>Topic</CODE> |
| * objects for those clients that need to dynamically manipulate |
| * provider-specific destination names. |
| * <LI>It supports a single series of transactions that combine work |
| * spanning its producers and consumers into atomic units. |
| * <LI>It defines a serial order for the messages it consumes and |
| * the messages it produces. |
| * <LI>It retains messages it consumes until they have been |
| * acknowledged. |
| * <LI>It serializes execution of message listeners registered with |
| * its message consumers. |
| * <LI> It is a factory for <CODE>QueueBrowsers</CODE>. |
| * </UL> |
| * |
| * <P>A session can create and service multiple message producers and |
| * consumers. |
| * |
| * <P>One typical use is to have a thread block on a synchronous |
| * <CODE>MessageConsumer</CODE> until a message arrives. The thread may then |
| * use one or more of the <CODE>Session</CODE>'s <CODE>MessageProducer</CODE>s. |
| * |
| * <P>If a client desires to have one thread produce messages while others |
| * consume them, the client should use a separate session for its producing |
| * thread. |
| * |
| * <P>Once a connection has been started, any session with one or more |
| * registered message listeners is dedicated to the thread of control that |
| * delivers messages to it. It is erroneous for client code to use this session |
| * or any of its constituent objects from another thread of control. The |
| * only exception to this rule is the use of the session or connection |
| * <CODE>close</CODE> method. |
| * |
| * <P>It should be easy for most clients to partition their work naturally |
| * into sessions. This model allows clients to start simply and incrementally |
| * add message processing complexity as their need for concurrency grows. |
| * |
| * <P>The <CODE>close</CODE> method is the only session method that can be |
| * called while some other session method is being executed in another thread. |
| * |
| * <P>A session may be specified as transacted. Each transacted |
| * session supports a single series of transactions. Each transaction groups |
| * a set of message sends and a set of message receives into an atomic unit |
| * of work. In effect, transactions organize a session's input message |
| * stream and output message stream into series of atomic units. When a |
| * transaction commits, its atomic unit of input is acknowledged and its |
| * associated atomic unit of output is sent. If a transaction rollback is |
| * done, the transaction's sent messages are destroyed and the session's input |
| * is automatically recovered. |
| * |
| * <P>The content of a transaction's input and output units is simply those |
| * messages that have been produced and consumed within the session's current |
| * transaction. |
| * |
| * <P>A transaction is completed using either its session's <CODE>commit</CODE> |
| * method or its session's <CODE>rollback</CODE> method. The completion of a |
| * session's current transaction automatically begins the next. The result is |
| * that a transacted session always has a current transaction within which its |
| * work is done. |
| * |
| * <P>The Java Transaction Service (JTS) or some other transaction monitor may |
| * be used to combine a session's transaction with transactions on other |
| * resources (databases, other JMS sessions, etc.). Since Java distributed |
| * transactions are controlled via the Java Transaction API (JTA), use of the |
| * session's <CODE>commit</CODE> and <CODE>rollback</CODE> methods in |
| * this context is prohibited. |
| * |
| * <P>The JMS API does not require support for JTA; however, it does define |
| * how a provider supplies this support. |
| * |
| * <P>Although it is also possible for a JMS client to handle distributed |
| * transactions directly, it is unlikely that many JMS clients will do this. |
| * Support for JTA in the JMS API is targeted at systems vendors who will be |
| * integrating the JMS API into their application server products. |
| * |
| * @version 1.1 February 2, 2002 |
| * @author Mark Hapner |
| * @author Rich Burridge |
| * @author Kate Stout |
| * |
| * @see javax.jms.QueueSession |
| * @see javax.jms.TopicSession |
| * @see javax.jms.XASession |
| */ |
| |
| public interface Session extends Runnable |
| { |
| |
| /** With this acknowledgment mode, the session automatically acknowledges |
| * a client's receipt of a message either when the session has successfully |
| * returned from a call to <CODE>receive</CODE> or when the message |
| * listener the session has called to process the message successfully |
| * returns. |
| */ |
| |
| static final int AUTO_ACKNOWLEDGE = 1; |
| |
| /** With this acknowledgment mode, the client acknowledges a consumed |
| * message by calling the message's <CODE>acknowledge</CODE> method. |
| * Acknowledging a consumed message acknowledges all messages that the |
| * session has consumed. |
| * |
| * <P>When client acknowledgment mode is used, a client may build up a |
| * large number of unacknowledged messages while attempting to process |
| * them. A JMS provider should provide administrators with a way to |
| * limit client overrun so that clients are not driven to resource |
| * exhaustion and ensuing failure when some resource they are using |
| * is temporarily blocked. |
| * |
| * @see javax.jms.Message#acknowledge() |
| */ |
| |
| static final int CLIENT_ACKNOWLEDGE = 2; |
| |
| /** This acknowledgment mode instructs the session to lazily acknowledge |
| * the delivery of messages. This is likely to result in the delivery of |
| * some duplicate messages if the JMS provider fails, so it should only be |
| * used by consumers that can tolerate duplicate messages. Use of this |
| * mode can reduce session overhead by minimizing the work the |
| * session does to prevent duplicates. |
| */ |
| |
| static final int DUPS_OK_ACKNOWLEDGE = 3; |
| |
| /** This value is returned from the method |
| * <CODE>getAcknowledgeMode</CODE> if the session is transacted. |
| * If a <CODE>Session</CODE> is transacted, the acknowledgement mode |
| * is ignored. |
| */ |
| static final int SESSION_TRANSACTED = 0; |
| |
| /** Creates a <CODE>BytesMessage</CODE> object. A <CODE>BytesMessage</CODE> |
| * object is used to send a message containing a stream of uninterpreted |
| * bytes. |
| * |
| * @exception JMSException if the JMS provider fails to create this message |
| * due to some internal error. |
| */ |
| |
| BytesMessage createBytesMessage() throws JMSException; |
| |
| /** Creates a <CODE>MapMessage</CODE> object. A <CODE>MapMessage</CODE> |
| * object is used to send a self-defining set of name-value pairs, where |
| * names are <CODE>String</CODE> objects and values are primitive values |
| * in the Java programming language. |
| * |
| * @exception JMSException if the JMS provider fails to create this message |
| * due to some internal error. |
| */ |
| |
| MapMessage createMapMessage() throws JMSException; |
| |
| /** Creates a <CODE>Message</CODE> object. The <CODE>Message</CODE> |
| * interface is the root interface of all JMS messages. A |
| * <CODE>Message</CODE> object holds all the |
| * standard message header information. It can be sent when a message |
| * containing only header information is sufficient. |
| * |
| * @exception JMSException if the JMS provider fails to create this message |
| * due to some internal error. |
| */ |
| |
| Message createMessage() throws JMSException; |
| |
| /** Creates an <CODE>ObjectMessage</CODE> object. An |
| * <CODE>ObjectMessage</CODE> object is used to send a message |
| * that contains a serializable Java object. |
| * |
| * @exception JMSException if the JMS provider fails to create this message |
| * due to some internal error. |
| */ |
| |
| ObjectMessage createObjectMessage() throws JMSException; |
| |
| /** Creates an initialized <CODE>ObjectMessage</CODE> object. An |
| * <CODE>ObjectMessage</CODE> object is used |
| * to send a message that contains a serializable Java object. |
| * |
| * @param object the object to use to initialize this message |
| * |
| * @exception JMSException if the JMS provider fails to create this message |
| * due to some internal error. |
| */ |
| |
| ObjectMessage createObjectMessage(Serializable object) throws JMSException; |
| |
| /** Creates a <CODE>StreamMessage</CODE> object. A |
| * <CODE>StreamMessage</CODE> object is used to send a |
| * self-defining stream of primitive values in the Java programming |
| * language. |
| * |
| * @exception JMSException if the JMS provider fails to create this message |
| * due to some internal error. |
| */ |
| |
| StreamMessage createStreamMessage() throws JMSException; |
| |
| /** Creates a <CODE>TextMessage</CODE> object. A <CODE>TextMessage</CODE> |
| * object is used to send a message containing a <CODE>String</CODE> |
| * object. |
| * |
| * @exception JMSException if the JMS provider fails to create this message |
| * due to some internal error. |
| */ |
| |
| TextMessage createTextMessage() throws JMSException; |
| |
| /** Creates an initialized <CODE>TextMessage</CODE> object. A |
| * <CODE>TextMessage</CODE> object is used to send |
| * a message containing a <CODE>String</CODE>. |
| * |
| * @param text the string used to initialize this message |
| * |
| * @exception JMSException if the JMS provider fails to create this message |
| * due to some internal error. |
| */ |
| |
| TextMessage createTextMessage(String text) throws JMSException; |
| |
| /** Indicates whether the session is in transacted mode. |
| * |
| * @return true if the session is in transacted mode |
| * |
| * @exception JMSException if the JMS provider fails to return the |
| * transaction mode due to some internal error. |
| */ |
| |
| boolean getTransacted() throws JMSException; |
| |
| /** Returns the acknowledgement mode of the session. The acknowledgement |
| * mode is set at the time that the session is created. If the session is |
| * transacted, the acknowledgement mode is ignored. |
| * |
| *@return If the session is not transacted, returns the |
| * current acknowledgement mode for the session. |
| * If the session |
| * is transacted, returns SESSION_TRANSACTED. |
| * |
| *@exception JMSException if the JMS provider fails to return the |
| * acknowledgment mode due to some internal error. |
| * |
| *@see Connection#createSession |
| *@since 1.1 |
| */ |
| int getAcknowledgeMode() throws JMSException; |
| |
| /** Commits all messages done in this transaction and releases any locks |
| * currently held. |
| * |
| * @exception JMSException if the JMS provider fails to commit the |
| * transaction due to some internal error. |
| * @exception TransactionRolledBackException if the transaction |
| * is rolled back due to some internal error |
| * during commit. |
| * @exception IllegalStateException if the method is not called by a |
| * transacted session. |
| */ |
| |
| void commit() throws JMSException; |
| |
| /** Rolls back any messages done in this transaction and releases any locks |
| * currently held. |
| * |
| * @exception JMSException if the JMS provider fails to roll back the |
| * transaction due to some internal error. |
| * @exception IllegalStateException if the method is not called by a |
| * transacted session. |
| * |
| */ |
| |
| void rollback() throws JMSException; |
| |
| /** Closes the session. |
| * |
| * <P>Since a provider may allocate some resources on behalf of a session |
| * outside the JVM, clients should close the resources when they are not |
| * needed. |
| * Relying on garbage collection to eventually reclaim these resources |
| * may not be timely enough. |
| * |
| * <P>There is no need to close the producers and consumers |
| * of a closed session. |
| * |
| * <P> This call will block until a <CODE>receive</CODE> call or message |
| * listener in progress has completed. A blocked message consumer |
| * <CODE>receive</CODE> call returns <CODE>null</CODE> when this session |
| * is closed. |
| * |
| * <P>Closing a transacted session must roll back the transaction |
| * in progress. |
| * |
| * <P>This method is the only <CODE>Session</CODE> method that can |
| * be called concurrently. |
| * |
| * <P>Invoking any other <CODE>Session</CODE> method on a closed session |
| * must throw a <CODE>JMSException.IllegalStateException</CODE>. Closing a |
| * closed session must <I>not</I> throw an exception. |
| * |
| * @exception JMSException if the JMS provider fails to close the |
| * session due to some internal error. |
| */ |
| |
| void close() throws JMSException; |
| |
| /** Stops message delivery in this session, and restarts message delivery |
| * with the oldest unacknowledged message. |
| * |
| * <P>All consumers deliver messages in a serial order. |
| * Acknowledging a received message automatically acknowledges all |
| * messages that have been delivered to the client. |
| * |
| * <P>Restarting a session causes it to take the following actions: |
| * |
| * <UL> |
| * <LI>Stop message delivery |
| * <LI>Mark all messages that might have been delivered but not |
| * acknowledged as "redelivered" |
| * <LI>Restart the delivery sequence including all unacknowledged |
| * messages that had been previously delivered. Redelivered messages |
| * do not have to be delivered in |
| * exactly their original delivery order. |
| * </UL> |
| * |
| * @exception JMSException if the JMS provider fails to stop and restart |
| * message delivery due to some internal error. |
| * @exception IllegalStateException if the method is called by a |
| * transacted session. |
| */ |
| |
| void recover() throws JMSException; |
| |
| /** Returns the session's distinguished message listener (optional). |
| * |
| * @return the message listener associated with this session |
| * |
| * @exception JMSException if the JMS provider fails to get the message |
| * listener due to an internal error. |
| * |
| * @see javax.jms.Session#setMessageListener |
| * @see javax.jms.ServerSessionPool |
| * @see javax.jms.ServerSession |
| */ |
| |
| MessageListener getMessageListener() throws JMSException; |
| |
| /** Sets the session's distinguished message listener (optional). |
| * |
| * <P>When the distinguished message listener is set, no other form of |
| * message receipt in the session can |
| * be used; however, all forms of sending messages are still supported. |
| * |
| * <P>This is an expert facility not used by regular JMS clients. |
| * |
| * @param listener the message listener to associate with this session |
| * |
| * @exception JMSException if the JMS provider fails to set the message |
| * listener due to an internal error. |
| * |
| * @see javax.jms.Session#getMessageListener |
| * @see javax.jms.ServerSessionPool |
| * @see javax.jms.ServerSession |
| */ |
| |
| void setMessageListener(MessageListener listener) throws JMSException; |
| |
| /** |
| * Optional operation, intended to be used only by Application Servers, |
| * not by ordinary JMS clients. |
| * |
| * @see javax.jms.ServerSession |
| */ |
| public void run(); |
| |
| /** Creates a <CODE>MessageProducer</CODE> to send messages to the specified |
| * destination. |
| * |
| * <P>A client uses a <CODE>MessageProducer</CODE> object to send |
| * messages to a destination. Since <CODE>Queue</CODE> and <CODE>Topic</CODE> |
| * both inherit from <CODE>Destination</CODE>, they can be used in |
| * the destination parameter to create a <CODE>MessageProducer</CODE> object. |
| * |
| * @param destination the <CODE>Destination</CODE> to send to, |
| * or null if this is a producer which does not have a specified |
| * destination. |
| * |
| * @exception JMSException if the session fails to create a MessageProducer |
| * due to some internal error. |
| * @exception InvalidDestinationException if an invalid destination |
| * is specified. |
| * |
| * @since 1.1 |
| * |
| */ |
| |
| MessageProducer createProducer(Destination destination) throws JMSException; |
| |
| /** Creates a <CODE>MessageConsumer</CODE> for the specified destination. |
| * Since <CODE>Queue</CODE> and <CODE>Topic</CODE> |
| * both inherit from <CODE>Destination</CODE>, they can be used in |
| * the destination parameter to create a <CODE>MessageConsumer</CODE>. |
| * |
| * @param destination the <CODE>Destination</CODE> to access. |
| * |
| * @exception JMSException if the session fails to create a consumer |
| * due to some internal error. |
| * @exception InvalidDestinationException if an invalid destination |
| * is specified. |
| * |
| * @since 1.1 |
| */ |
| |
| MessageConsumer createConsumer(Destination destination) throws JMSException; |
| |
| /** Creates a <CODE>MessageConsumer</CODE> for the specified destination, |
| * using a message selector. |
| * Since <CODE>Queue</CODE> and <CODE>Topic</CODE> |
| * both inherit from <CODE>Destination</CODE>, they can be used in |
| * the destination parameter to create a <CODE>MessageConsumer</CODE>. |
| * |
| * <P>A client uses a <CODE>MessageConsumer</CODE> object to receive |
| * messages that have been sent to a destination. |
| * |
| * |
| * @param destination the <CODE>Destination</CODE> to access |
| * @param messageSelector only messages with properties matching the |
| * message selector expression are delivered. A value of null or |
| * an empty string indicates that there is no message selector |
| * for the message consumer. |
| * |
| * |
| * @exception JMSException if the session fails to create a MessageConsumer |
| * due to some internal error. |
| * @exception InvalidDestinationException if an invalid destination |
| * is specified. |
| |
| * @exception InvalidSelectorException if the message selector is invalid. |
| * |
| * @since 1.1 |
| */ |
| MessageConsumer createConsumer(Destination destination, java.lang.String messageSelector) throws JMSException; |
| |
| /** Creates <CODE>MessageConsumer</CODE> for the specified destination, using a |
| * message selector. This method can specify whether messages published by |
| * its own connection should be delivered to it, if the destination is a |
| * topic. |
| *<P> Since <CODE>Queue</CODE> and <CODE>Topic</CODE> |
| * both inherit from <CODE>Destination</CODE>, they can be used in |
| * the destination parameter to create a <CODE>MessageConsumer</CODE>. |
| * <P>A client uses a <CODE>MessageConsumer</CODE> object to receive |
| * messages that have been published to a destination. |
| * |
| * <P>In some cases, a connection may both publish and subscribe to a |
| * topic. The consumer <CODE>NoLocal</CODE> attribute allows a consumer |
| * to inhibit the delivery of messages published by its own connection. |
| * The default value for this attribute is False. The <CODE>noLocal</CODE> |
| * value must be supported by destinations that are topics. |
| * |
| * @param destination the <CODE>Destination</CODE> to access |
| * @param messageSelector only messages with properties matching the |
| * message selector expression are delivered. A value of null or |
| * an empty string indicates that there is no message selector |
| * for the message consumer. |
| * @param NoLocal - if true, and the destination is a topic, |
| * inhibits the delivery of messages published |
| * by its own connection. The behavior for |
| * <CODE>NoLocal</CODE> is |
| * not specified if the destination is a queue. |
| * |
| * @exception JMSException if the session fails to create a MessageConsumer |
| * due to some internal error. |
| * @exception InvalidDestinationException if an invalid destination |
| * is specified. |
| |
| * @exception InvalidSelectorException if the message selector is invalid. |
| * |
| * @since 1.1 |
| * |
| */ |
| MessageConsumer createConsumer(Destination destination, java.lang.String messageSelector, boolean NoLocal) throws JMSException; |
| |
| /** Creates a queue identity given a <CODE>Queue</CODE> name. |
| * |
| * <P>This facility is provided for the rare cases where clients need to |
| * dynamically manipulate queue identity. It allows the creation of a |
| * queue identity with a provider-specific name. Clients that depend |
| * on this ability are not portable. |
| * |
| * <P>Note that this method is not for creating the physical queue. |
| * The physical creation of queues is an administrative task and is not |
| * to be initiated by the JMS API. The one exception is the |
| * creation of temporary queues, which is accomplished with the |
| * <CODE>createTemporaryQueue</CODE> method. |
| * |
| * @param queueName the name of this <CODE>Queue</CODE> |
| * |
| * @return a <CODE>Queue</CODE> with the given name |
| * |
| * @exception JMSException if the session fails to create a queue |
| * due to some internal error. |
| * @since 1.1 |
| */ |
| |
| Queue createQueue(String queueName) throws JMSException; |
| |
| /** Creates a topic identity given a <CODE>Topic</CODE> name. |
| * |
| * <P>This facility is provided for the rare cases where clients need to |
| * dynamically manipulate topic identity. This allows the creation of a |
| * topic identity with a provider-specific name. Clients that depend |
| * on this ability are not portable. |
| * |
| * <P>Note that this method is not for creating the physical topic. |
| * The physical creation of topics is an administrative task and is not |
| * to be initiated by the JMS API. The one exception is the |
| * creation of temporary topics, which is accomplished with the |
| * <CODE>createTemporaryTopic</CODE> method. |
| * |
| * @param topicName the name of this <CODE>Topic</CODE> |
| * |
| * @return a <CODE>Topic</CODE> with the given name |
| * |
| * @exception JMSException if the session fails to create a topic |
| * due to some internal error. |
| * @since 1.1 |
| */ |
| |
| Topic createTopic(String topicName) throws JMSException; |
| |
| /** Creates a <CODE>QueueBrowser</CODE> object to peek at the messages on |
| * the specified queue. |
| * |
| * @param queue the <CODE>queue</CODE> to access |
| * |
| * @exception InvalidDestinationException if an invalid destination |
| * is specified |
| * |
| * @since 1.1 |
| */ |
| |
| /** Creates a durable subscriber to the specified topic. |
| * |
| * <P>If a client needs to receive all the messages published on a |
| * topic, including the ones published while the subscriber is inactive, |
| * it uses a durable <CODE>TopicSubscriber</CODE>. The JMS provider |
| * retains a record of this |
| * durable subscription and insures that all messages from the topic's |
| * publishers are retained until they are acknowledged by this |
| * durable subscriber or they have expired. |
| * |
| * <P>Sessions with durable subscribers must always provide the same |
| * client identifier. In addition, each client must specify a name that |
| * uniquely identifies (within client identifier) each durable |
| * subscription it creates. Only one session at a time can have a |
| * <CODE>TopicSubscriber</CODE> for a particular durable subscription. |
| * |
| * <P>A client can change an existing durable subscription by creating |
| * a durable <CODE>TopicSubscriber</CODE> with the same name and a new |
| * topic and/or |
| * message selector. Changing a durable subscriber is equivalent to |
| * unsubscribing (deleting) the old one and creating a new one. |
| * |
| * <P>In some cases, a connection may both publish and subscribe to a |
| * topic. The subscriber <CODE>NoLocal</CODE> attribute allows a subscriber |
| * to inhibit the delivery of messages published by its own connection. |
| * The default value for this attribute is false. |
| * |
| * @param topic the non-temporary <CODE>Topic</CODE> to subscribe to |
| * @param name the name used to identify this subscription |
| * |
| * @exception JMSException if the session fails to create a subscriber |
| * due to some internal error. |
| * @exception InvalidDestinationException if an invalid topic is specified. |
| * |
| * @since 1.1 |
| */ |
| |
| TopicSubscriber createDurableSubscriber(Topic topic, String name) throws JMSException; |
| |
| /** Creates a durable subscriber to the specified topic, using a |
| * message selector and specifying whether messages published by its |
| * own connection should be delivered to it. |
| * |
| * <P>If a client needs to receive all the messages published on a |
| * topic, including the ones published while the subscriber is inactive, |
| * it uses a durable <CODE>TopicSubscriber</CODE>. The JMS provider |
| * retains a record of this |
| * durable subscription and insures that all messages from the topic's |
| * publishers are retained until they are acknowledged by this |
| * durable subscriber or they have expired. |
| * |
| * <P>Sessions with durable subscribers must always provide the same |
| * client identifier. In addition, each client must specify a name which |
| * uniquely identifies (within client identifier) each durable |
| * subscription it creates. Only one session at a time can have a |
| * <CODE>TopicSubscriber</CODE> for a particular durable subscription. |
| * An inactive durable subscriber is one that exists but |
| * does not currently have a message consumer associated with it. |
| * |
| * <P>A client can change an existing durable subscription by creating |
| * a durable <CODE>TopicSubscriber</CODE> with the same name and a new |
| * topic and/or |
| * message selector. Changing a durable subscriber is equivalent to |
| * unsubscribing (deleting) the old one and creating a new one. |
| * |
| * @param topic the non-temporary <CODE>Topic</CODE> to subscribe to |
| * @param name the name used to identify this subscription |
| * @param messageSelector only messages with properties matching the |
| * message selector expression are delivered. A value of null or |
| * an empty string indicates that there is no message selector |
| * for the message consumer. |
| * @param noLocal if set, inhibits the delivery of messages published |
| * by its own connection |
| * |
| * @exception JMSException if the session fails to create a subscriber |
| * due to some internal error. |
| * @exception InvalidDestinationException if an invalid topic is specified. |
| * @exception InvalidSelectorException if the message selector is invalid. |
| * |
| * @since 1.1 |
| */ |
| |
| TopicSubscriber createDurableSubscriber(Topic topic, String name, String messageSelector, boolean noLocal) throws JMSException; |
| |
| /** Creates a <CODE>QueueBrowser</CODE> object to peek at the messages on |
| * the specified queue. |
| * |
| * @param queue the <CODE>queue</CODE> to access |
| * |
| * |
| * @exception JMSException if the session fails to create a browser |
| * due to some internal error. |
| * @exception InvalidDestinationException if an invalid destination |
| * is specified |
| * |
| * @since 1.1 |
| */ |
| QueueBrowser createBrowser(Queue queue) throws JMSException; |
| |
| /** Creates a <CODE>QueueBrowser</CODE> object to peek at the messages on |
| * the specified queue using a message selector. |
| * |
| * @param queue the <CODE>queue</CODE> to access |
| * |
| * @param messageSelector only messages with properties matching the |
| * message selector expression are delivered. A value of null or |
| * an empty string indicates that there is no message selector |
| * for the message consumer. |
| * |
| * @exception JMSException if the session fails to create a browser |
| * due to some internal error. |
| * @exception InvalidDestinationException if an invalid destination |
| * is specified |
| * @exception InvalidSelectorException if the message selector is invalid. |
| * |
| * @since 1.1 |
| */ |
| |
| QueueBrowser createBrowser(Queue queue, String messageSelector) throws JMSException; |
| |
| /** Creates a <CODE>TemporaryQueue</CODE> object. Its lifetime will be that |
| * of the <CODE>Connection</CODE> unless it is deleted earlier. |
| * |
| * @return a temporary queue identity |
| * |
| * @exception JMSException if the session fails to create a temporary queue |
| * due to some internal error. |
| * |
| *@since 1.1 |
| */ |
| |
| TemporaryQueue createTemporaryQueue() throws JMSException; |
| |
| /** Creates a <CODE>TemporaryTopic</CODE> object. Its lifetime will be that |
| * of the <CODE>Connection</CODE> unless it is deleted earlier. |
| * |
| * @return a temporary topic identity |
| * |
| * @exception JMSException if the session fails to create a temporary |
| * topic due to some internal error. |
| * |
| * @since 1.1 |
| */ |
| |
| TemporaryTopic createTemporaryTopic() throws JMSException; |
| |
| /** Unsubscribes a durable subscription that has been created by a client. |
| * |
| * <P>This method deletes the state being maintained on behalf of the |
| * subscriber by its provider. |
| * |
| * <P>It is erroneous for a client to delete a durable subscription |
| * while there is an active <CODE>MessageConsumer</CODE> |
| * or <CODE>TopicSubscriber</CODE> for the |
| * subscription, or while a consumed message is part of a pending |
| * transaction or has not been acknowledged in the session. |
| * |
| * @param name the name used to identify this subscription |
| * |
| * @exception JMSException if the session fails to unsubscribe to the |
| * durable subscription due to some internal error. |
| * @exception InvalidDestinationException if an invalid subscription name |
| * is specified. |
| * |
| * @since 1.1 |
| */ |
| |
| void unsubscribe(String name) throws JMSException; |
| |
| } |