public class OutboundTopicConnection extends OutboundConnection implements javax.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 org.objectweb.util.monolog.api.Logger |
logger |
managedCx, sessions, valid, xac
Constructor and Description |
---|
OutboundTopicConnection(ManagedConnectionImpl managedCx,
javax.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. |
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Topic topic,
String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages)
Forbidden call on an application or component's outbound connection,
throws a
IllegalStateException instance. |
javax.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
OutboundTopicConnection(ManagedConnectionImpl managedCx, javax.jms.XATopicConnection xac)
OutboundTopicConnection
instance.managedCx
- The managed connection building the handle.xac
- The underlying physical PubSub connection to handle.public javax.jms.TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
OutboundTopicSession
instance.createTopicSession
in interface javax.jms.TopicConnection
javax.jms.IllegalStateException
- If the handle is invalid.javax.jms.JMSException
- Generic exception.public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic, String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) throws javax.jms.JMSException
IllegalStateException
instance.createConnectionConsumer
in interface javax.jms.TopicConnection
javax.jms.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 © 2018 ScalAgent D.T.. All Rights Reserved.