public class TopicSession extends Session implements javax.jms.TopicSession
javax.jms.TopicSession
interface.Session.Closer
deliveries, INDIVIDUAL_ACKNOWLEDGE, listener, logger, messageConsumerListeners, messageListener, sendings, trace, transacted
Constructor and Description |
---|
TopicSession(Connection cnx,
boolean transacted,
int acknowledgeMode,
RequestMultiplexer mtpx)
Constructs a topic session.
|
Modifier and Type | Method and Description |
---|---|
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue)
API method.
|
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue,
String selector)
API method.
|
javax.jms.TopicPublisher |
createPublisher(javax.jms.Topic topic)
API method.
|
javax.jms.Queue |
createQueue(String queueName)
API method.
|
javax.jms.TopicSubscriber |
createSubscriber(javax.jms.Topic topic)
API method.
|
javax.jms.TopicSubscriber |
createSubscriber(javax.jms.Topic topic,
String selector,
boolean noLocal)
API method.
|
javax.jms.TemporaryQueue |
createTemporaryQueue()
API method.
|
String |
toString()
Returns a String image of this session.
|
acknowledge, acknowledge, addConsumer, addMessageListener, addProducer, checkClosed, checkConsumers, checkThread, close, closeBrowser, closeConsumer, closeProducer, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableConsumer, createDurableConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createSharedConsumer, createSharedConsumer, createSharedDurableConsumer, createSharedDurableConsumer, createStreamMessage, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, doClose, getAcknowledgeMode, getCompressedMinSize, getCompressionLevel, getConnection, getId, getJMXBeanName, getMessageConsumerListener, getMessageListener, getQueueMessageReadMax, getRequestMultiplexer, getRequestStatus, getSessionMode, getStatus, getTopicAckBufferMax, getTopicActivationThreshold, getTopicPassivationThreshold, getTransacted, isAsyncSend, isAsyncSub, isAutoAck, isImplicitAck, isStarted, onMessage, onMessage, pushMessages, putMessageConsumerListener, receive, recover, registerMBean, removeMessageConsumerListener, removeMessageListener, rollback, run, send, setAsyncSend, setAsyncSub, setCompressedMinSize, setCompressionLevel, setImplicitAck, setMessageConsumerListener, setMessageListener, setQueueMessageReadMax, setTopicAckBufferMax, setTopicActivationThreshold, setTopicPassivationThreshold, setTransacted, start, stop, syncRequest, unregisterMBean, unsubscribe
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createDurableSubscriber, createDurableSubscriber, createTemporaryTopic, createTopic, unsubscribe
close, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener
TopicSession(Connection cnx, boolean transacted, int acknowledgeMode, RequestMultiplexer mtpx) throws javax.jms.JMSException
cnx
- The connection the session belongs to.transacted
- true
for a transacted session.acknowledgeMode
- 1 (auto), 2 (client) or 3 (dups ok).javax.jms.JMSException
- In case of an invalid acknowledge mode.public String toString()
public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic) throws javax.jms.JMSException
createPublisher
in interface javax.jms.TopicSession
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.public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic, String selector, boolean noLocal) throws javax.jms.JMSException
createSubscriber
in interface javax.jms.TopicSession
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.public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic) throws javax.jms.JMSException
createSubscriber
in interface javax.jms.TopicSession
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.public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue, String selector) throws javax.jms.JMSException
createBrowser
in interface javax.jms.Session
createBrowser
in class Session
queue
- the queue to browseselector
- the expression allowing to filter messagesjavax.jms.IllegalStateException
- Systematically.javax.jms.JMSException
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue) throws javax.jms.JMSException
createBrowser
in interface javax.jms.Session
createBrowser
in class Session
queue
- the queue to browsejavax.jms.IllegalStateException
- Systematically.javax.jms.JMSException
public javax.jms.Queue createQueue(String queueName) throws javax.jms.JMSException
createQueue
in interface javax.jms.Session
createQueue
in class Session
queueName
- the name of this queue.javax.jms.IllegalStateException
- Systematically.javax.jms.JMSException
- If the topic creation failed.Queue
public javax.jms.TemporaryQueue createTemporaryQueue() throws javax.jms.JMSException
createTemporaryQueue
in interface javax.jms.Session
createTemporaryQueue
in class Session
javax.jms.IllegalStateException
- Systematically.javax.jms.JMSException
- If the request fails for any other reason.TemporaryQueue
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.