public class OutboundTopicConnection extends OutboundConnection implements jakarta.jms.TopicConnection
OutboundTopicConnection
instance is a handler for a
physical PubSub connection to an underlying JORAM server, allowing a
component to transparently use this physical connection possibly within
a transaction (local or global).Modifier and Type | Field and Description |
---|---|
static Logger |
logger |
managedCx, sessions, valid, xac
Constructor and Description |
---|
OutboundTopicConnection(ManagedConnectionImpl managedCx,
jakarta.jms.XATopicConnection xac)
Constructs an
OutboundTopicConnection instance. |
Modifier and Type | Method and Description |
---|---|
boolean |
cnxEquals(Object obj)
Returns
true if the parameter is a Connection instance sharing the same
proxy identifier and connection key. |
jakarta.jms.ConnectionConsumer |
createConnectionConsumer(jakarta.jms.Topic topic,
String messageSelector,
jakarta.jms.ServerSessionPool sessionPool,
int maxMessages)
Forbidden call on an application or component's outbound connection,
throws a
IllegalStateException instance. |
jakarta.jms.TopicSession |
createTopicSession(boolean transacted,
int acknowledgeMode)
Returns the unique authorized JMS session per connection wrapped in
an
OutboundTopicSession instance. |
cleanup, close, createConnectionConsumer, createDurableConnectionConsumer, createSession, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, getClientID, getExceptionListener, getJMXBeanName, getMetaData, getNumberOfSession, getSessions, registerMBean, setClientID, setExceptionListener, start, stop, toString, unregisterMBean
public static Logger logger
OutboundTopicConnection(ManagedConnectionImpl managedCx, jakarta.jms.XATopicConnection xac)
OutboundTopicConnection
instance.managedCx
- The managed connection building the handle.xac
- The underlying physical PubSub connection to handle.public boolean cnxEquals(Object obj)
OutboundConnection
true
if the parameter is a Connection
instance sharing the same
proxy identifier and connection key.cnxEquals
in class OutboundConnection
public jakarta.jms.TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws jakarta.jms.JMSException
OutboundTopicSession
instance.createTopicSession
in interface jakarta.jms.TopicConnection
jakarta.jms.IllegalStateException
- If the handle is invalid.jakarta.jms.JMSException
- Generic exception.public jakarta.jms.ConnectionConsumer createConnectionConsumer(jakarta.jms.Topic topic, String messageSelector, jakarta.jms.ServerSessionPool sessionPool, int maxMessages) throws jakarta.jms.JMSException
IllegalStateException
instance.createConnectionConsumer
in interface jakarta.jms.TopicConnection
jakarta.jms.JMSException
Copyright © 2023 ScalAgent D.T.. All rights reserved.