org.objectweb.joram.client.jms
Class QueueConnection

java.lang.Object
  org.objectweb.joram.client.jms.Connection
      org.objectweb.joram.client.jms.QueueConnection

All Implemented Interfaces:

javax.jms.Connection, javax.jms.QueueConnection

Direct Known 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

logger

Constructor Summary

QueueConnection(FactoryParameters factoryParameters, RequestChannel requestChannel)
Creates a QueueConnection instance.

Method Summary

javax.jms.ConnectionConsumer	createConnectionConsumer(javax.jms.Queue queue, java.lang.String selector, javax.jms.ServerSessionPool sessionPool, int maxMessages) API method.
javax.jms.ConnectionConsumer	createDurableConnectionConsumer(javax.jms.Topic topic, java.lang.String subname, java.lang.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

addSession, checkClosed, cleanup, close, createConnectionConsumer, createSession, equals, getAsyncSend, getClientID, getExceptionListener, getImplicitAck, getInInterceptors, getMetaData, getOutInterceptors, getOutLocalAddress, getOutLocalPort, getQueueMessageReadMax, getRequestMultiplexer, getTopicAckBufferMax, getTopicActivationThreshold, getTopicPassivationThreshold, getTxPendingTimer, hashCode, setClientID, setExceptionListener, start, stop, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface javax.jms.Connection

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

Constructor Detail

QueueConnection

public QueueConnection(FactoryParameters factoryParameters,
                       RequestChannel requestChannel)
                throws javax.jms.JMSException

Creates a QueueConnection instance.

Parameters:

factoryParameters - The factory parameters.

requestChannel - The actual connection to wrap.

Throws:

JMSSecurityException - If the user identification is incorrect.

javax.jms.IllegalStateException - If the server is not listening.

javax.jms.JMSException

Method Detail

createConnectionConsumer

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

API method.

Specified by:

createConnectionConsumer in interface javax.jms.QueueConnection

Throws:

javax.jms.IllegalStateException - If the connection is closed.

InvalidSelectorException - If the selector syntax is wrong.

InvalidDestinationException - If the target destination does not exist.

javax.jms.JMSException - If the method fails for any other reason.

createQueueSession

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

API method.

Specified by:

createQueueSession in interface javax.jms.QueueConnection

Throws:

javax.jms.IllegalStateException - If the connection is closed.

javax.jms.JMSException - In case of an invalid acknowledge mode.

createDurableConnectionConsumer

public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic,
                                                                    java.lang.String subname,
                                                                    java.lang.String selector,
                                                                    javax.jms.ServerSessionPool sessPool,
                                                                    int maxMessages)
                                                             throws javax.jms.JMSException

API method.

Specified by:

createDurableConnectionConsumer in interface javax.jms.Connection

Overrides:

createDurableConnectionConsumer in class Connection

Throws:

javax.jms.IllegalStateException - Systematically.

javax.jms.InvalidSelectorException - If the selector syntax is wrong.

javax.jms.InvalidDestinationException - If the target topic does not exist.

javax.jms.JMSException - If the method fails for any other reason.