org.objectweb.joram.client.jms
Class Connection
java.lang.Object
org.objectweb.joram.client.jms.Connection
- javax.jms.Connection
public class Connection
extends java.lang.Object
implements javax.jms.Connection
Implements the javax.jms.Connection
interface.
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.
|
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.
|
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.
Connection
public Connection(FactoryParameters factoryParameters,
ConnectionItf connectionImpl)
throws JMSException
Creates a Connection
instance.
factoryParameters
- The factory parameters.connectionImpl
- The actual connection to wrap.
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