com.caucho.jms.connection
Class QueueConnectionImpl

java.lang.Object
  extended by com.caucho.jms.connection.ConnectionImpl
      extended by 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