public class OutboundTopicConnection extends OutboundConnection implements 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 org.objectweb.util.monolog.api.Logger |
logger |
managedCx, sessions, valid, xac
Constructor and Description |
---|
OutboundTopicConnection(ManagedConnectionImpl managedCx,
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. |
ConnectionConsumer |
createConnectionConsumer(Topic topic,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
Forbidden call on an application or component's outbound connection,
throws a
IllegalStateException instance. |
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createDurableConnectionConsumer
close, createConnectionConsumer, createSession, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
OutboundTopicConnection(ManagedConnectionImpl managedCx, XATopicConnection xac)
OutboundTopicConnection
instance.managedCx
- The managed connection building the handle.xac
- The underlying physical PubSub connection to handle.public TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws JMSException
OutboundTopicSession
instance.createTopicSession
in interface TopicConnection
IllegalStateException
- If the handle is invalid.JMSException
- Generic exception.public ConnectionConsumer createConnectionConsumer(Topic topic, String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException
IllegalStateException
instance.createConnectionConsumer
in interface TopicConnection
JMSException
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
Copyright © 2021 ScalAgent D.T.. All rights reserved.