public class TopicConnection extends Connection implements jakarta.jms.TopicConnection
jakarta.jms.TopicConnection
interface.Connection.AtomicCounter, Connection.Closer
JMXBeanBaseName, logger, MESSAGE_ID_PREFIX_PROPERTY, messageConsumers, tracker
Constructor and Description |
---|
TopicConnection()
Creates a
TopicConnection instance. |
Modifier and Type | Method and Description |
---|---|
jakarta.jms.ConnectionConsumer |
createConnectionConsumer(jakarta.jms.Topic topic,
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.TopicSession |
createTopicSession(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.Topic topic, String selector, jakarta.jms.ServerSessionPool sessionPool, int maxMessages) throws jakarta.jms.JMSException
createConnectionConsumer
in interface jakarta.jms.TopicConnection
topic
- the topic 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 consumer.maxMessages
- 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.TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws jakarta.jms.JMSException
createTopicSession
in interface jakarta.jms.TopicConnection
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 interface jakarta.jms.TopicConnection
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
- If the connection is closed.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.