org.objectweb.joram.client.jms

Class Connection

Implemented Interfaces:
javax.jms.Connection
Known Direct Subclasses:
QueueConnection, TopicConnection, XAConnection

public class Connection
extends java.lang.Object
implements javax.jms.Connection

Implements the javax.jms.Connection interface.

Field Summary

Hashtable
repliesTable
Table holding the server replies to synchronous requests.
Hashtable
requestsTable
Table holding requests related objects, either locks of synchronous requests, or asynchronous consumers.
Vector
sessions
Vector of the connection's sessions.

Constructor Summary

Connection(FactoryParameters factoryParameters, ConnectionItf connectionImpl)
Creates a Connection instance.

Method Summary

void
close()
API method for closing the connection; even if the connection appears to be broken, closes the sessions.
javax.jms.ConnectionConsumer
createConnectionConsumer(javax.jms.Destination dest, String selector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
API method.
javax.jms.ConnectionConsumer
createDurableConnectionConsumer(javax.jms.Topic topic, String subName, String selector, javax.jms.ServerSessionPool sessPool, int maxMessages)
API method.
javax.jms.Session
createSession(boolean transacted, int acknowledgeMode)
API method.
boolean
equals(Object obj)
Specializes this Object method; returns true if the parameter is a Connection instance sharing the same proxy identifier and connection key.
String
getClientID()
API method.
javax.jms.ExceptionListener
getExceptionListener()
API method.
javax.jms.ConnectionMetaData
getMetaData()
API method.
void
setClientID(String clientID)
API method.
void
setExceptionListener(javax.jms.ExceptionListener listener)
API method.
void
start()
API method for starting the connection.
void
stop()
API method for stopping the connection; even if the connection appears to be broken, stops the sessions.
String
toString()
String image of the connection.

Field Details

repliesTable

public Hashtable repliesTable
Table holding the server replies to synchronous requests.


requestsTable

public Hashtable requestsTable
Table holding requests related objects, either locks of synchronous requests, or asynchronous consumers.


sessions

public Vector sessions
Vector of the connection's sessions.

Constructor Details

Connection

public Connection(FactoryParameters factoryParameters,
                  ConnectionItf connectionImpl)
            throws JMSException
Creates a Connection instance.

Parameters:
factoryParameters - The factory parameters.
connectionImpl - The actual connection to wrap.

Method Details

close

public void close()
            throws JMSException
API method for closing the connection; even if the connection appears to be broken, closes the sessions.


createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination dest,
                                                             String selector,
                                                             javax.jms.ServerSessionPool sessionPool,
                                                             int maxMessages)
            throws JMSException
API method.


createDurableConnectionConsumer

public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic,
                                                                    String subName,
                                                                    String selector,
                                                                    javax.jms.ServerSessionPool sessPool,
                                                                    int maxMessages)
            throws JMSException
API method.


createSession

public javax.jms.Session createSession(boolean transacted,
                                       int acknowledgeMode)
            throws JMSException
API method.


equals

public boolean equals(Object obj)
Specializes this Object method; returns true if the parameter is a Connection instance sharing the same proxy identifier and connection key.


getClientID

public String getClientID()
            throws JMSException
API method.


getExceptionListener

public javax.jms.ExceptionListener getExceptionListener()
            throws JMSException
API method.


getMetaData

public javax.jms.ConnectionMetaData getMetaData()
            throws JMSException
API method.


setClientID

public void setClientID(String clientID)
            throws JMSException
API method.


setExceptionListener

public void setExceptionListener(javax.jms.ExceptionListener listener)
            throws JMSException
API method.


start

public void start()
            throws JMSException
API method for starting the connection.


stop

public void stop()
            throws JMSException
API method for stopping the connection; even if the connection appears to be broken, stops the sessions.


toString

public String toString()
String image of the connection.


Copyright B) 2004 Scalagent - All rights reserved