org.objectweb.joram.client.jms
Class TopicSession

java.lang.Object
  extended by org.objectweb.joram.client.jms.Session
      extended by 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.


Nested Class Summary
 
Nested classes/interfaces inherited from class org.objectweb.joram.client.jms.Session
Session.Closer
 
Field Summary
 
Fields inherited from class org.objectweb.joram.client.jms.Session
deliveries, logger, messageListener, sendings, transacted
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
 
Constructor Summary
TopicSession(Connection cnx, boolean transacted, int acknowledgeMode, RequestMultiplexer mtpx)
          Constructs a topic session.
 
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
acknowledge, addConsumer, addMessageListener, addProducer, checkClosed, checkConsumers, close, closeBrowser, closeConsumer, closeProducer, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, doClose, getAckMode, getAcknowledgeMode, getConnection, getId, getMessageListener, getQueueMessageReadMax, getRequestMultiplexer, getTopicAckBufferMax, getTopicActivationThreshold, getTopicPassivationThreshold, getTransacted, isAsyncSend, isAsyncSub, isAutoAck, isImplicitAck, isStarted, onMessage, onMessage, pushMessages, receive, recover, removeMessageListener, rollback, run, send, setAsyncSend, setAsyncSub, setImplicitAck, setInMessageInterceptors, setMessageConsumerListener, setMessageListener, setOutMessageInterceptors, setQueueMessageReadMax, setTopicAckBufferMax, setTopicActivationThreshold, setTopicPassivationThreshold, setTransacted, start, stop, syncRequest, 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
 

Constructor Detail

TopicSession

TopicSession(Connection cnx,
             boolean transacted,
             int acknowledgeMode,
             RequestMultiplexer mtpx)
       throws javax.jms.JMSException
Constructs a topic session.

Parameters:
cnx - The connection the session belongs to.
transacted - true for a transacted session.
acknowledgeMode - 1 (auto), 2 (client) or 3 (dups ok).
Throws:
javax.jms.JMSException - In case of an invalid acknowledge mode.
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 - If the topic creation failed.

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.


Copyright © 2010 ScalAgent D.T.. All Rights Reserved.