| Method Summary |
|
| public void | acknowledge()
|
| protected void | addConsumer(MessageConsumerImpl consumer)
|
| void | addTransactedReceive(AbstractDestination queue, MessageImpl message)
Adds a message to the session message queue. |
| public void | checkOpen()
Checks that the session is open. |
| void | checkThread()
Verifies that multiple threads aren't using the session.
4.4.1 the client takes the responsibility. |
| public void | close()
|
| public void | commit()
Commits the messages. |
| public void | commit(Xid xid, boolean onePhase)
Called to commit. |
| public QueueBrowser | createBrowser(Queue queue)
Creates a QueueBrowser to browse messages in the queue. |
| public QueueBrowser | createBrowser(Queue queue, String messageSelector)
Creates a QueueBrowser to browse messages in the queue. |
| public BytesMessage | createBytesMessage()
Creates a new byte[] message. |
| public MessageConsumer | createConsumer(Destination destination)
Creates a consumer to receive messages. |
| public MessageConsumer | createConsumer(Destination destination, String messageSelector)
Creates a consumer to receive messages. |
| public MessageConsumer | createConsumer(Destination destination, String messageSelector, boolean noLocal)
Creates a consumer to receive messages. |
| public TopicSubscriber | createDurableSubscriber(Topic topic, String name)
Creates a durable subscriber to receive messages. |
| public TopicSubscriber | createDurableSubscriber(Topic topic, String name, String messageSelector, boolean noLocal)
Creates a subscriber to receive messages. |
| public MapMessage | createMapMessage()
Creates a new map message. |
| public Message | createMessage()
Creates a message. |
| public ObjectMessage | createObjectMessage()
Creates an object message. |
| public ObjectMessage | createObjectMessage(Serializable obj)
Creates an object message. |
| public MessageProducer | createProducer(Destination destination)
Creates a producer to produce messages. |
| public Queue | createQueue(String queueName)
Creates a new queue. |
| public StreamMessage | createStreamMessage()
Creates a stream message. |
| public TemporaryQueue | createTemporaryQueue()
Creates a temporary queue. |
| public TemporaryTopic | createTemporaryTopic()
Creates a temporary topic. |
| public TextMessage | createTextMessage()
Creates a text message. |
| public TextMessage | createTextMessage(String message)
Creates a text message. |
| public Topic | createTopic(String topicName)
Creates a new topic. |
| public void | end(Xid xid, int flags)
Called when the resource is is done with a transaction. |
| public void | forget(Xid xid)
Called to forget an Xid that had a heuristic commit. |
| public int | getAcknowledgeMode()
Returns the acknowledge mode for the session. |
| ClassLoader | getClassLoader()
Returns the ClassLoader. |
| public String | getClientID()
|
| ConnectionImpl | getConnection()
Returns the connection. |
| public MessageListener | getMessageListener()
|
| public Session | getSession()
|
| public boolean | getTransacted()
Returns true if the session is in a transaction. |
| public int | getTransactionTimeout()
Gets the transaction timeout in seconds. |
| public XAResource | getXAResource()
|
| public boolean | isActive()
Returns true if the connection is active. |
| boolean | isAsynchronous()
Set true for a synchronous session. |
| public boolean | isClosed()
|
| public boolean | isSameRM(XAResource xa)
Returns true if the specified resource has the same RM. |
| boolean | isStopping()
Returns true if the connection is active. |
| boolean | notifyMessageAvailable()
Notifies the receiver. |
| public int | prepare(Xid xid)
Called to start the first phase of the commit. |
| protected Message | receive(MessageConsumerImpl consumer, long timeout)
Called to synchronously receive a message. |
| public void | recover()
Recovers the messages. |
| public Xid[] | recover(int flag)
Called to find Xid's that need recovery. |
| protected void | removeConsumer(MessageConsumerImpl consumer)
|
| public void | rollback()
Rollsback the messages. |
| public void | rollback(Xid xid)
Called to roll back. |
| public void | rollbackImpl()
Rollsback the messages. |
| public void | run()
|
| public void | send(AbstractDestination queue, Message appMessage, int deliveryMode, int priority, long timeout)
Adds a message to the session message queue. |
| void | setAsynchronous()
Set true for a synchronous session. |
| public void | setMessageListener(MessageListener listener)
|
| public boolean | setTransactionTimeout(int timeout)
Sets the transaction timeout in seconds. |
| void | start()
Starts the session. |
| public void | start(Xid xid, int flags)
Called when the resource is associated with a transaction. |
| void | stop()
Stops the session. |
| public String | toString()
|
| public void | unsubscribe(String name)
Unsubscribe from a durable subscription. |
