Joram ${version}

org.objectweb.joram.client.jms
Class QueueConnection

java.lang.Object
  extended byorg.objectweb.joram.client.jms.Connection
      extended byorg.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.


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 name, 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, getClientID, getExceptionListener, getMetaData, getRequestMultiplexer, setClientID, setExceptionListener, start, stop, toString
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, hashCode, 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.
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 name,
                                                                    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.JMSException - If the method fails for any other reason.

Joram ${version}

Copyright ? 2005 Scalagent - All rights reserved