org.objectweb.joram.client.jms

Class QueueConnection

Implemented Interfaces:
javax.jms.Connection, javax.jms.QueueConnection
Known Direct Subclasses:
XAQueueConnection

public class QueueConnection
extends Connection
implements javax.jms.QueueConnection

Implements the javax.jms.QueueConnection interface.

Field Summary

Fields inherited from class org.objectweb.joram.client.jms.Connection

repliesTable, requestsTable, sessions

Constructor Summary

QueueConnection(FactoryParameters factoryParameters, ConnectionItf connectionImpl)
Creates a QueueConnection instance.

Method Summary

javax.jms.ConnectionConsumer
createConnectionConsumer(javax.jms.Queue queue, String selector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
API method.
javax.jms.ConnectionConsumer
createDurableConnectionConsumer(javax.jms.Topic topic, String name, String selector, javax.jms.ServerSessionPool sessPool, int maxMessages)
API method.
javax.jms.QueueSession
createQueueSession(boolean transacted, int acknowledgeMode)
API method.

Methods inherited from class org.objectweb.joram.client.jms.Connection

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

Constructor Details

QueueConnection

public QueueConnection(FactoryParameters factoryParameters,
                       ConnectionItf connectionImpl)
            throws JMSException
Creates a QueueConnection instance.

Parameters:
factoryParameters - The factory parameters.
connectionImpl - The actual connection to wrap.

Method Details

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue,
                                                             String selector,
                                                             javax.jms.ServerSessionPool sessionPool,
                                                             int maxMessages)
            throws JMSException
API method.


createDurableConnectionConsumer

public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic,
                                                                    String name,
                                                                    String selector,
                                                                    javax.jms.ServerSessionPool sessPool,
                                                                    int maxMessages)
            throws JMSException
API method.
Overrides:
createDurableConnectionConsumer in interface Connection


createQueueSession

public javax.jms.QueueSession createQueueSession(boolean transacted,
                                                 int acknowledgeMode)
            throws JMSException
API method.


Copyright B) 2004 Scalagent - All rights reserved