public class TopicConnection extends Connection implements TopicConnection
javax.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 |
---|---|
ConnectionConsumer |
createConnectionConsumer(Topic topic,
String selector,
ServerSessionPool sessionPool,
int maxMessages)
API method.
|
ConnectionConsumer |
createDurableConnectionConsumer(Topic topic,
String subName,
String selector,
ServerSessionPool sessPool,
int maxMessages)
API method.
|
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
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
close, createConnectionConsumer, createSession, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
public ConnectionConsumer createConnectionConsumer(Topic topic, String selector, ServerSessionPool sessionPool, int maxMessages) throws JMSException
createConnectionConsumer
in interface 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.IllegalStateException
- If the connection is closed.InvalidSelectorException
- If the selector syntax is wrong.InvalidDestinationException
- If the target destination does
not exist.JMSException
- If the method fails for any other reason.public TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws JMSException
createTopicSession
in interface 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.IllegalStateException
- If the connection is closed.JMSException
- In case of an invalid acknowledge mode.public ConnectionConsumer createDurableConnectionConsumer(Topic topic, String subName, String selector, ServerSessionPool sessPool, int maxMessages) throws JMSException
createDurableConnectionConsumer
in interface Connection
createDurableConnectionConsumer
in interface 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.IllegalStateException
- If the connection is closed.InvalidSelectorException
- If the selector syntax is wrong.InvalidDestinationException
- If the target topic does
not exist.JMSException
- If the method fails for any other reason.Copyright © 2021 ScalAgent D.T.. All rights reserved.