org.objectweb.joram.client.jms
Class TopicSession

java.lang.Object
  org.objectweb.joram.client.jms.Session
      org.objectweb.joram.client.jms.TopicSession

All Implemented Interfaces:

java.lang.Runnable, javax.jms.Session, javax.jms.TopicSession

public class TopicSession
extends Session
implements javax.jms.TopicSession

Implements the javax.jms.TopicSession interface.

Field Summary

Fields inherited from class org.objectweb.joram.client.jms.Session

logger, messageListener

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Method Summary

javax.jms.QueueBrowser	createBrowser(javax.jms.Queue queue) API method.
javax.jms.QueueBrowser	createBrowser(javax.jms.Queue queue, java.lang.String selector) API method.
javax.jms.TopicPublisher	createPublisher(javax.jms.Topic topic) API method.
javax.jms.Queue	createQueue(java.lang.String queueName) API method.
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic) API method.
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic, java.lang.String selector, boolean noLocal) API method.
javax.jms.TemporaryQueue	createTemporaryQueue() API method.
java.lang.String	toString() Returns a String image of this session.

Methods inherited from class org.objectweb.joram.client.jms.Session

addConsumer, addProducer, checkClosed, close, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, getAcknowledgeMode, getMessageListener, getQueueMessageReadMax, getTopicAckBufferMax, getTopicActivationThreshold, getTopicPassivationThreshold, getTransacted, isAsyncSend, isAsyncSub, isAutoAck, isImplicitAck, recover, rollback, run, setAsyncSend, setAsyncSub, setImplicitAck, setInMessageInterceptors, setMessageListener, setOutMessageInterceptors, setQueueMessageReadMax, setTopicAckBufferMax, setTopicActivationThreshold, setTopicPassivationThreshold, setTransacted, unsubscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface javax.jms.TopicSession

createDurableSubscriber, createDurableSubscriber, createTemporaryTopic, createTopic, unsubscribe

Methods inherited from interface javax.jms.Session

close, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener

Method Detail

toString

public java.lang.String toString()

Returns a String image of this session.

Overrides:

toString in class Session

createPublisher

public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
                                         throws javax.jms.JMSException

API method.

Specified by:

createPublisher in interface javax.jms.TopicSession

Throws:

javax.jms.IllegalStateException - If the session is closed or if the connection is broken.

javax.jms.JMSException - If the creation fails for any other reason.

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic,
                                                  java.lang.String selector,
                                                  boolean noLocal)
                                           throws javax.jms.JMSException

API method.

Specified by:

createSubscriber in interface javax.jms.TopicSession

Throws:

javax.jms.IllegalStateException - If the session is closed or if the connection is broken.

javax.jms.JMSException - If the creation fails for any other reason.

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
                                           throws javax.jms.JMSException

API method.

Specified by:

createSubscriber in interface javax.jms.TopicSession

Throws:

javax.jms.IllegalStateException - If the session is closed or if the connection is broken.

javax.jms.JMSException - If the creation fails for any other reason.

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue,
                                            java.lang.String selector)
                                     throws javax.jms.JMSException

API method.

Specified by:

createBrowser in interface javax.jms.Session

Overrides:

createBrowser in class Session

Parameters:

queue - the queue to browse

selector - the expression allowing to filter messages

Throws:

javax.jms.IllegalStateException - Systematically.

javax.jms.JMSException

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
                                     throws javax.jms.JMSException

API method.

Specified by:

createBrowser in interface javax.jms.Session

Overrides:

createBrowser in class Session

Parameters:

queue - the queue to browse

Throws:

javax.jms.IllegalStateException - Systematically.

javax.jms.JMSException

createQueue

public javax.jms.Queue createQueue(java.lang.String queueName)
                            throws javax.jms.JMSException

API method.

Specified by:

createQueue in interface javax.jms.Session

Overrides:

createQueue in class Session

Throws:

javax.jms.IllegalStateException - Systematically.

javax.jms.JMSException

createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue()
                                              throws javax.jms.JMSException

API method.

Specified by:

createTemporaryQueue in interface javax.jms.Session

Overrides:

createTemporaryQueue in class Session

Throws:

javax.jms.IllegalStateException - Systematically.

javax.jms.JMSException - If the request fails for any other reason.