org.exolab.jms.client
Class JmsQueueConnection

java.lang.Object
  |
  +--org.exolab.jms.client.JmsConnection
        |
        +--org.exolab.jms.client.JmsQueueConnection

All Implemented Interfaces:

javax.jms.Connection, javax.jms.QueueConnection

Direct Known Subclasses:

JmsXAQueueConnection

public class JmsQueueConnection

extends JmsConnection

implements javax.jms.QueueConnection

The JmsQueueConnection class is responsible for allocating sessions..

Version:

$Revision: 1.10 $ $Date: 2003/08/07 13:32:50 $

Author:

Jim Alateras

See Also:

QueueConnection

Method Summary

javax.jms.ConnectionConsumer	createConnectionConsumer(javax.jms.Queue queue, java.lang.String selector, javax.jms.ServerSessionPool pool, int maxMessages)
javax.jms.QueueSession	createQueueSession(boolean transacted, int ackMode)

Methods inherited from class org.exolab.jms.client.JmsConnection

addSession, close, destroy, ensureOpen, getClientID, getConnectionId, getExceptionListener, getMetaData, getSessions, isManaged, isStopped, notifyExceptionListener, removeSession, setClientID, setExceptionListener, setModified, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.jms.Connection

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

Method Detail

createQueueSession

public javax.jms.QueueSession createQueueSession(boolean transacted,
                                                 int ackMode)
                                          throws javax.jms.JMSException

Specified by:

createQueueSession in interface javax.jms.QueueConnection

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue,
                                                             java.lang.String selector,
                                                             javax.jms.ServerSessionPool pool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException

Specified by:

createConnectionConsumer in interface javax.jms.QueueConnection