com.caucho.jms.connection
Class QueueConnectionImpl

java.lang.Object
  com.caucho.jms.connection.ConnectionImpl
      com.caucho.jms.connection.QueueConnectionImpl

All Implemented Interfaces:

Connection, QueueConnection, XAConnection, XAQueueConnection

public class QueueConnectionImpl
extends ConnectionImpl
implements XAQueueConnection

A sample queue connection factory.

Constructor Summary

QueueConnectionImpl(ConnectionFactoryImpl factory)
Create a new queue connection.

QueueConnectionImpl(ConnectionFactoryImpl factory, boolean isXA)
Create a new queue connection.

Method Summary

ConnectionConsumer	createConnectionConsumer(Queue queue, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages) Creates a new consumer (optional)
QueueSession	createQueueSession(boolean transacted, int acknowledgeMode) Creates a new connection session.
XAQueueSession	createXAQueueSession() Creates a new connection session.

Methods inherited from class com.caucho.jms.connection.ConnectionImpl

addSession, assignClientID, checkOpen, close, createConnectionConsumer, createDurableConnectionConsumer, createSession, createXASession, getClientID, getConnectionFactory, getExceptionListener, getMetaData, isXA, 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.XAConnection

createSession, createXASession

Methods inherited from interface javax.jms.Connection

close, createConnectionConsumer, createDurableConnectionConsumer, getClientID, getExceptionListener, getMetaData, setClientID, setExceptionListener, start, stop

Constructor Detail

QueueConnectionImpl

public QueueConnectionImpl(ConnectionFactoryImpl factory,
                           boolean isXA)

Create a new queue connection.

QueueConnectionImpl

public QueueConnectionImpl(ConnectionFactoryImpl factory)

Create a new queue connection.

Method Detail

createConnectionConsumer

public ConnectionConsumer createConnectionConsumer(Queue queue,
                                                   java.lang.String messageSelector,
                                                   ServerSessionPool sessionPool,
                                                   int maxMessages)
                                            throws JMSException

Creates a new consumer (optional)

Specified by:

createConnectionConsumer in interface QueueConnection

Throws:

JMSException

createQueueSession

public QueueSession createQueueSession(boolean transacted,
                                       int acknowledgeMode)
                                throws JMSException

Creates a new connection session.

Specified by:

createQueueSession in interface QueueConnection

Specified by:

createQueueSession in interface XAQueueConnection

Throws:

JMSException

createXAQueueSession

public XAQueueSession createXAQueueSession()
                                    throws JMSException

Creates a new connection session.

Specified by:

createXAQueueSession in interface XAQueueConnection

Throws:

JMSException