org.objectweb.joram.client.connector
Class OutboundQueueConnection

java.lang.Object
  extended by org.objectweb.joram.client.connector.OutboundConnection
      extended by org.objectweb.joram.client.connector.OutboundQueueConnection
All Implemented Interfaces:
javax.jms.Connection, javax.jms.QueueConnection

public class OutboundQueueConnection
extends OutboundConnection
implements javax.jms.QueueConnection

An 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).


Field Summary
 
Fields inherited from class org.objectweb.joram.client.connector.OutboundConnection
managedCx, sessions, valid, xac
 
Constructor Summary
OutboundQueueConnection(ManagedConnectionImpl managedCx, javax.jms.XAQueueConnection xac)
          Constructs an OutboundQueueConnection instance.
 
Method Summary
 javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue, java.lang.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.
 
Methods inherited from class org.objectweb.joram.client.connector.OutboundConnection
cleanup, close, cnxEquals, createConnectionConsumer, createDurableConnectionConsumer, createSession, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface javax.jms.Connection
close, createConnectionConsumer, createDurableConnectionConsumer, createSession, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop
 

Constructor Detail

OutboundQueueConnection

OutboundQueueConnection(ManagedConnectionImpl managedCx,
                        javax.jms.XAQueueConnection xac)
Constructs an OutboundQueueConnection instance.

Parameters:
managedCx - The managed connection building the handle.
xac - The underlying physical PTP connection to handle.
Method Detail

createQueueSession

public javax.jms.QueueSession createQueueSession(boolean transacted,
                                                 int acknowledgeMode)
                                          throws javax.jms.JMSException
Returns the unique authorized JMS session per connection wrapped in an OutboundQueueSession instance.

Specified by:
createQueueSession in interface javax.jms.QueueConnection
Throws:
javax.jms.IllegalStateException - If the handle is invalid.
javax.jms.JMSException - Generic exception.

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue,
                                                             java.lang.String messageSelector,
                                                             javax.jms.ServerSessionPool sessionPool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.

Specified by:
createConnectionConsumer in interface javax.jms.QueueConnection
Throws:
javax.jms.JMSException


Copyright © 2010 ScalAgent D.T.. All Rights Reserved.