public class OutboundQueueConnection extends OutboundConnection implements QueueConnection
OutboundQueueConnection
instance is a handler for a
physical PTP 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 |
---|
OutboundQueueConnection(ManagedConnectionImpl managedCx,
XAQueueConnection xac)
Constructs an
OutboundQueueConnection 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(Queue queue,
String messageSelector,
ServerSessionPool sessionPool,
int maxMessages)
Forbidden call on an application or component's outbound connection,
throws a
IllegalStateException instance. |
QueueSession |
createQueueSession(boolean transacted,
int acknowledgeMode)
Returns the unique authorized JMS session per connection wrapped in
an
OutboundQueueSession 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
close, createConnectionConsumer, createDurableConnectionConsumer, createSession, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
OutboundQueueConnection(ManagedConnectionImpl managedCx, XAQueueConnection xac)
OutboundQueueConnection
instance.managedCx
- The managed connection building the handle.xac
- The underlying physical PTP connection to handle.public QueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws JMSException
OutboundQueueSession
instance.createQueueSession
in interface QueueConnection
IllegalStateException
- If the handle is invalid.JMSException
- Generic exception.public ConnectionConsumer createConnectionConsumer(Queue queue, String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException
IllegalStateException
instance.createConnectionConsumer
in interface QueueConnection
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 © 2016 ScalAgent D.T.. All Rights Reserved.