public class QueueConnection extends Connection implements jakarta.jms.QueueConnection
jakarta.jms.QueueConnection
interface.Connection.AtomicCounter, Connection.Closer
JMXBeanBaseName, logger, MESSAGE_ID_PREFIX_PROPERTY, messageConsumers, tracker
Constructor and Description |
---|
QueueConnection()
Creates a
QueueConnection instance. |
Modifier and Type | Method and Description |
---|---|
jakarta.jms.ConnectionConsumer |
createConnectionConsumer(jakarta.jms.Queue queue,
String selector,
jakarta.jms.ServerSessionPool sessionPool,
int maxMessages)
API method.
|
jakarta.jms.ConnectionConsumer |
createDurableConnectionConsumer(jakarta.jms.Topic topic,
String subname,
String selector,
jakarta.jms.ServerSessionPool sessPool,
int maxMessages)
API method.
|
jakarta.jms.QueueSession |
createQueueSession(boolean transacted,
int acknowledgeMode)
API method.
|
addSession, checkCLMessageProducer, checkClosed, checkCLSession, checkConsumers, checkThread, cleanup, close, closeConnectionConsumer, closeMessageConsumer, closeSession, createConnectionConsumer, createSession, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, doClose, equals, getAsyncSend, getClientID, getCompressedMinSize, getCompressionLevel, getExceptionListener, getImplicitAck, getInInterceptors, getJMXBeanName, getMetaData, getOutInterceptors, getOutLocalAddress, getOutLocalPort, getProxyId, getQueueMessageReadMax, getRequestMultiplexer, getTopicAckBufferMax, getTopicActivationThreshold, getTopicPassivationThreshold, getTxPendingTimer, hashCode, isOpenMessageConsumer, isStopped, lockClientId, nextMessageId, nextSessionId, nextSubName, open, openMessageConsumer, registerMBean, setClientID, setExceptionListener, setJMXBeanBaseName, setProviderClientID, start, stop, syncRequest, toString, unregisterMBean
public jakarta.jms.ConnectionConsumer createConnectionConsumer(jakarta.jms.Queue queue, String selector, jakarta.jms.ServerSessionPool sessionPool, int maxMessages) throws jakarta.jms.JMSException
createConnectionConsumer
in interface jakarta.jms.QueueConnection
queue
- the queue to access.selector
- only messages with properties matching the message selector expression
are delivered. A value of null or an empty string indicates that there
is no message selector for this message consumer.sessionPool
- the server session pool to associate with this connection consumermaxMessages
- the maximum number of messages that can be assigned to a server session
at one time.jakarta.jms.IllegalStateException
- If the connection is closed.jakarta.jms.InvalidSelectorException
- If the selector syntax is wrong.jakarta.jms.InvalidDestinationException
- If the target destination does
not exist.jakarta.jms.JMSException
- If the method fails for any other reason.public jakarta.jms.QueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws jakarta.jms.JMSException
createQueueSession
in interface jakarta.jms.QueueConnection
transacted
- indicates whether the session is transacted.acknowledgeMode
- indicates whether the consumer or the client will acknowledge any
messages it receives; ignored if the session is transacted. Legal
values are Session.AUTO_ACKNOWLEDGE, Session.CLIENT_ACKNOWLEDGE, and
Session.DUPS_OK_ACKNOWLEDGE.jakarta.jms.IllegalStateException
- If the connection is closed.jakarta.jms.JMSException
- In case of an invalid acknowledge mode.public jakarta.jms.ConnectionConsumer createDurableConnectionConsumer(jakarta.jms.Topic topic, String subname, String selector, jakarta.jms.ServerSessionPool sessPool, int maxMessages) throws jakarta.jms.JMSException
createDurableConnectionConsumer
in interface jakarta.jms.Connection
createDurableConnectionConsumer
in class Connection
topic
- the topic to access.subname
- durable subscription name.selector
- only messages with properties matching the message selector expression
are delivered. A value of null or an empty string indicates that there
is no message selector for this message consumer.sessPool
- the server session pool to associate with this connection consumer.maxMessages
- the maximum number of messages that can be assigned to a server session
at one time.jakarta.jms.IllegalStateException
- Systematically.jakarta.jms.InvalidSelectorException
- If the selector syntax is wrong.jakarta.jms.InvalidDestinationException
- If the target topic does
not exist.jakarta.jms.JMSException
- If the method fails for any other reason.Copyright © 2022 ScalAgent D.T.. All rights reserved.