public class QueueSession extends Session implements jakarta.jms.QueueSession
jakarta.jms.QueueSession
interface.Session.Closer
deliveries, INDIVIDUAL_ACKNOWLEDGE, listener, logger, messageConsumerListeners, messageListener, sendings, trace, tracker, transacted
Constructor and Description |
---|
QueueSession(Connection cnx,
boolean transacted,
int acknowledgeMode,
RequestMultiplexer mtpx)
Constructs a queue session.
|
Modifier and Type | Method and Description |
---|---|
jakarta.jms.MessageConsumer |
createDurableConsumer(jakarta.jms.Topic topic,
String name)
API 2.0 method.
|
jakarta.jms.MessageConsumer |
createDurableConsumer(jakarta.jms.Topic topic,
String name,
String messageSelector,
boolean noLocal)
API 2.0 method.
|
jakarta.jms.TopicSubscriber |
createDurableSubscriber(jakarta.jms.Topic topic,
String name)
API method.
|
jakarta.jms.TopicSubscriber |
createDurableSubscriber(jakarta.jms.Topic topic,
String name,
String selector,
boolean noLocal)
API method.
|
jakarta.jms.QueueReceiver |
createReceiver(jakarta.jms.Queue queue)
API method.
|
jakarta.jms.QueueReceiver |
createReceiver(jakarta.jms.Queue queue,
String selector)
API method.
|
jakarta.jms.QueueSender |
createSender(jakarta.jms.Queue queue)
API method.
|
jakarta.jms.MessageConsumer |
createSharedConsumer(jakarta.jms.Topic topic,
String name)
API 2.0 method.
|
jakarta.jms.MessageConsumer |
createSharedConsumer(jakarta.jms.Topic topic,
String name,
String selector)
API 2.0 method.
|
jakarta.jms.MessageConsumer |
createSharedDurableConsumer(jakarta.jms.Topic topic,
String name)
API 2.0 method.
|
jakarta.jms.MessageConsumer |
createSharedDurableConsumer(jakarta.jms.Topic topic,
String name,
String selector)
API 2.0 method.
|
jakarta.jms.TemporaryTopic |
createTemporaryTopic()
API method.
|
jakarta.jms.Topic |
createTopic(String topicName)
API method.
|
void |
unsubscribe(String name)
API method.
|
acknowledge, acknowledge, addConsumer, addMessageListener, addProducer, checkClosed, checkConsumers, checkThread, close, closeBrowser, closeConsumer, closeProducer, commit, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createStreamMessage, createTemporaryQueue, createTextMessage, createTextMessage, 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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createBrowser, createBrowser, createQueue, createTemporaryQueue
close, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener
QueueSession(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.QueueSender createSender(jakarta.jms.Queue queue) throws jakarta.jms.JMSException
createSender
in interface jakarta.jms.QueueSession
queue
- the queue to send to, or null if this is a sender which does
not have a specified destination.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.QueueReceiver createReceiver(jakarta.jms.Queue queue, String selector) throws jakarta.jms.JMSException
createReceiver
in interface jakarta.jms.QueueSession
queue
- the queue to access.selector
- The selector allowing to filter messages.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.QueueReceiver createReceiver(jakarta.jms.Queue queue) throws jakarta.jms.JMSException
createReceiver
in interface jakarta.jms.QueueSession
queue
- the queue to access.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 createDurableSubscriber(jakarta.jms.Topic topic, String name, String selector, boolean noLocal) throws jakarta.jms.JMSException
createDurableSubscriber
in interface jakarta.jms.Session
createDurableSubscriber
in class Session
topic
- the non-temporary Topic to subscribe to.name
- the name used to identify this subscription.selector
- The selector allowing to filter messages. A value of null or an empty string
indicates that there is no message selector for the message consumer.noLocal
- if true, inhibits the delivery of messages published by its own connection.jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.InvalidDestinationException
- if an invalid destination is specified.jakarta.jms.JMSException
- If the creation fails for any other reason.public jakarta.jms.TopicSubscriber createDurableSubscriber(jakarta.jms.Topic topic, String name) throws jakarta.jms.JMSException
createDurableSubscriber
in interface jakarta.jms.Session
createDurableSubscriber
in class Session
topic
- the non-temporary Topic to subscribe to.name
- the name used to identify this subscription.jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.InvalidDestinationException
- if an invalid destination is specified.jakarta.jms.JMSException
- If the creation fails for any other reason.public jakarta.jms.Topic createTopic(String topicName) throws jakarta.jms.JMSException
createTopic
in interface jakarta.jms.Session
createTopic
in class Session
topicName
- the name of this topic.jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.JMSException
- If the topic creation failed.Topic
public jakarta.jms.TemporaryTopic createTemporaryTopic() throws jakarta.jms.JMSException
createTemporaryTopic
in interface jakarta.jms.Session
createTemporaryTopic
in class Session
jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.JMSException
- If the request fails for any other reason.TemporaryTopic
public void unsubscribe(String name) throws jakarta.jms.JMSException
unsubscribe
in interface jakarta.jms.Session
unsubscribe
in interface SessionMBean
unsubscribe
in class Session
name
- the name used to identify this subscription.jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.InvalidDestinationException
- If the subscription does not
exist.jakarta.jms.JMSException
- If the request fails for any other reason.public jakarta.jms.MessageConsumer createSharedConsumer(jakarta.jms.Topic topic, String name) throws jakarta.jms.JMSException
createSharedConsumer
in interface jakarta.jms.Session
createSharedConsumer
in class Session
jakarta.jms.JMSException
public jakarta.jms.MessageConsumer createSharedConsumer(jakarta.jms.Topic topic, String name, String selector) throws jakarta.jms.JMSException
createSharedConsumer
in interface jakarta.jms.Session
createSharedConsumer
in class Session
jakarta.jms.JMSException
public jakarta.jms.MessageConsumer createDurableConsumer(jakarta.jms.Topic topic, String name) throws jakarta.jms.JMSException
createDurableConsumer
in interface jakarta.jms.Session
createDurableConsumer
in class Session
topic
- the non-temporary Topic to subscribe to.name
- the name used to identify this subscription.jakarta.jms.InvalidDestinationException
- if an invalid destination is specified.jakarta.jms.IllegalStateException
- If the session is closed or if the
connection is broken or if the client identifier is unset.jakarta.jms.JMSException
- If the creation fails for any other reason.public jakarta.jms.MessageConsumer createDurableConsumer(jakarta.jms.Topic topic, String name, String messageSelector, boolean noLocal) throws jakarta.jms.JMSException
createDurableConsumer
in interface jakarta.jms.Session
createDurableConsumer
in class Session
topic
- the non-temporary Topic to subscribe to.name
- the name used to identify this subscription.messageSelector
- the selector used to filter incoming messages.noLocal
- if true, inhibits the delivery of messages published by its own connection.jakarta.jms.InvalidDestinationException
- if an invalid destination is specified.jakarta.jms.IllegalStateException
- If the session is closed or if the
connection is broken or if the client identifier is unset.jakarta.jms.JMSException
- If the creation fails for any other reason.public jakarta.jms.MessageConsumer createSharedDurableConsumer(jakarta.jms.Topic topic, String name) throws jakarta.jms.JMSException
createSharedDurableConsumer
in interface jakarta.jms.Session
createSharedDurableConsumer
in class Session
jakarta.jms.JMSException
public jakarta.jms.MessageConsumer createSharedDurableConsumer(jakarta.jms.Topic topic, String name, String selector) throws jakarta.jms.JMSException
createSharedDurableConsumer
in interface jakarta.jms.Session
createSharedDurableConsumer
in class Session
jakarta.jms.JMSException
Copyright © 2023 ScalAgent D.T.. All rights reserved.