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 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
public static Logger logger
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 © 2023 ScalAgent D.T.. All rights reserved.