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