public class TopicSession extends Session implements TopicSession
javax.jms.TopicSession
interface.Session.Closer
deliveries, INDIVIDUAL_ACKNOWLEDGE, listener, logger, messageConsumerListeners, messageListener, sendings, trace, tracker, transacted
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
Constructor and Description |
---|
TopicSession(Connection cnx,
boolean transacted,
int acknowledgeMode,
RequestMultiplexer mtpx)
Constructs a topic session.
|
Modifier and Type | Method and Description |
---|---|
QueueBrowser |
createBrowser(Queue queue)
API method.
|
QueueBrowser |
createBrowser(Queue queue,
String selector)
API method.
|
TopicPublisher |
createPublisher(Topic topic)
API method.
|
Queue |
createQueue(String queueName)
API method.
|
TopicSubscriber |
createSubscriber(Topic topic)
API method.
|
TopicSubscriber |
createSubscriber(Topic topic,
String selector,
boolean noLocal)
API method.
|
TemporaryQueue |
createTemporaryQueue()
API method.
|
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, toString, 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 JMSException
cnx
- The connection the session belongs to.transacted
- true
for a transacted session.acknowledgeMode
- 1 (auto), 2 (client) or 3 (dups ok).JMSException
- In case of an invalid acknowledge mode.public TopicPublisher createPublisher(Topic topic) throws JMSException
createPublisher
in interface TopicSession
IllegalStateException
- If the session is closed or if the
connection is broken.JMSException
- If the creation fails for any other reason.public TopicSubscriber createSubscriber(Topic topic, String selector, boolean noLocal) throws JMSException
createSubscriber
in interface TopicSession
IllegalStateException
- If the session is closed or if the
connection is broken.JMSException
- If the creation fails for any other reason.public TopicSubscriber createSubscriber(Topic topic) throws JMSException
createSubscriber
in interface TopicSession
IllegalStateException
- If the session is closed or if the
connection is broken.JMSException
- If the creation fails for any other reason.public QueueBrowser createBrowser(Queue queue, String selector) throws JMSException
createBrowser
in interface Session
createBrowser
in class Session
queue
- the queue to browseselector
- the expression allowing to filter messagesIllegalStateException
- Systematically.JMSException
public QueueBrowser createBrowser(Queue queue) throws JMSException
createBrowser
in interface Session
createBrowser
in class Session
queue
- the queue to browseIllegalStateException
- Systematically.JMSException
public Queue createQueue(String queueName) throws JMSException
createQueue
in interface Session
createQueue
in class Session
queueName
- the name of this queue.IllegalStateException
- Systematically.JMSException
- If the topic creation failed.Queue
public TemporaryQueue createTemporaryQueue() throws JMSException
createTemporaryQueue
in interface Session
createTemporaryQueue
in class Session
IllegalStateException
- Systematically.JMSException
- If the request fails for any other reason.TemporaryQueue
Copyright © 2021 ScalAgent D.T.. All rights reserved.