org.objectweb.joram.client.connector

Class OutboundQueueConnection

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

Method Summary

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.

Methods inherited from class org.objectweb.joram.client.connector.OutboundConnection

cleanup, close, cnxEquals, createConnectionConsumer, createDurableConnectionConsumer, createSession, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop, toString

Method Details

createConnectionConsumer

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


createQueueSession

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


Copyright B) 2004 Scalagent - All rights reserved