public class OutboundQueueConnection extends OutboundConnection implements javax.jms.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,
javax.jms.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. |
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Queue queue,
String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages)
Forbidden call on an application or component's outbound connection,
throws a
IllegalStateException instance. |
javax.jms.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, createSession, createSession, createSharedConnectionConsumer, createSharedDurableConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
OutboundQueueConnection(ManagedConnectionImpl managedCx, javax.jms.XAQueueConnection xac)
OutboundQueueConnection
instance.managedCx
- The managed connection building the handle.xac
- The underlying physical PTP connection to handle.public javax.jms.QueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
OutboundQueueSession
instance.createQueueSession
in interface javax.jms.QueueConnection
javax.jms.IllegalStateException
- If the handle is invalid.javax.jms.JMSException
- Generic exception.public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue, String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) throws javax.jms.JMSException
IllegalStateException
instance.createConnectionConsumer
in interface javax.jms.QueueConnection
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.