org.huihoo.jfox.ms.jms.queue
Class QueueConnectionImpl

java.lang.Object
  org.huihoo.jfox.ms.jms.base.ConnectionImpl
      org.huihoo.jfox.ms.jms.queue.QueueConnectionImpl

All Implemented Interfaces:

javax.jms.Connection, javax.jms.QueueConnection

public class QueueConnectionImpl

extends ConnectionImpl

implements javax.jms.QueueConnection

A QueueConnection object is an active connection to a point-to-point JMS provider. A client uses a QueueConnection object to create one or more QueueSession objects for producing and consuming messages.

Version:

Revision: 1.1 Date: 2002-05-19 22:37:37

Author:

Peter.Cheng

Constructor Summary

QueueConnectionImpl(QueueConnectionFactoryImpl connFactory, java.lang.String password, java.lang.String username)

Method Summary

javax.jms.ConnectionConsumer	createConnectionConsumer(javax.jms.Queue queue, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) Creates a QueueSession object.
javax.jms.QueueSession	createQueueSession(boolean transacted, int acknowledgeMode) Creates a connection consumer for this connection (optional operation).

Methods inherited from class org.huihoo.jfox.ms.jms.base.ConnectionImpl

addSession, close, getClientID, getExceptionListener, getMetaData, isClosed, isStopped, removeSession, setClientID, setExceptionListener, 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

Constructor Detail

QueueConnectionImpl

public QueueConnectionImpl(QueueConnectionFactoryImpl connFactory,
                           java.lang.String password,
                           java.lang.String username)

Method Detail

createConnectionConsumer

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

Creates a QueueSession object.

Specified by:

createConnectionConsumer in interface javax.jms.QueueConnection

Parameters:

queue -

messageSelector -

sessionPool -

maxMessages -

Returns:

@throws JMSException

Throws:

javax.jms.JMSException

createQueueSession

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

Creates a connection consumer for this connection (optional operation). This is an expert facility not used by regular JMS clients.

Specified by:

createQueueSession in interface javax.jms.QueueConnection

Parameters:

transacted -

acknowledgeMode -

Returns:

@throws JMSException

Throws:

javax.jms.JMSException