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, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, 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 © 2019 ScalAgent D.T.. All rights reserved.