|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.joram.client.jms.Connection
Implements the javax.jms.Connection
interface.
Field Summary | |
java.util.Hashtable |
repliesTable
Table holding the server replies to synchronous requests. |
java.util.Hashtable |
requestsTable
Table holding requests related objects, either locks of synchronous requests, or asynchronous consumers. |
java.util.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,
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.Session |
createSession(boolean transacted,
int acknowledgeMode)
API method. |
boolean |
equals(java.lang.Object obj)
Specializes this Object method; returns true if the
parameter is a Connection instance sharing the same
proxy identifier and connection key. |
java.lang.String |
getClientID()
API method. |
javax.jms.ExceptionListener |
getExceptionListener()
API method. |
javax.jms.ConnectionMetaData |
getMetaData()
API method. |
void |
setClientID(java.lang.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. |
java.lang.String |
toString()
String image of the connection. |
Methods inherited from class java.lang.Object |
clone, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
public java.util.Vector sessions
public java.util.Hashtable requestsTable
public java.util.Hashtable repliesTable
Constructor Detail |
public Connection(FactoryParameters factoryParameters, ConnectionItf connectionImpl) throws javax.jms.JMSException
Connection
instance.
factoryParameters
- The factory parameters.connectionImpl
- The actual connection to wrap.
javax.jms.JMSSecurityException
- If the user identification is incorrect.
javax.jms.IllegalStateException
- If the server is not listening.
javax.jms.JMSException
Method Detail |
public java.lang.String toString()
public boolean equals(java.lang.Object obj)
true
if the
parameter is a Connection
instance sharing the same
proxy identifier and connection key.
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination dest, java.lang.String selector, javax.jms.ServerSessionPool sessionPool, int maxMessages) throws javax.jms.JMSException
createConnectionConsumer
in interface javax.jms.Connection
javax.jms.IllegalStateException
- If the connection is closed.
InvalidSelectorException
- If the selector syntax is wrong.
javax.jms.InvalidDestinationException
- If the target destination does
not exist.
javax.jms.JMSException
- If the method fails for any other reason.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
createDurableConnectionConsumer
in interface javax.jms.Connection
javax.jms.IllegalStateException
- If the connection is closed.
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.public javax.jms.Session createSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
createSession
in interface javax.jms.Connection
javax.jms.IllegalStateException
- If the connection is closed.
javax.jms.JMSException
- In case of an invalid acknowledge mode.public void setExceptionListener(javax.jms.ExceptionListener listener) throws javax.jms.JMSException
setExceptionListener
in interface javax.jms.Connection
javax.jms.IllegalStateException
- If the connection is closed.
javax.jms.JMSException
public javax.jms.ExceptionListener getExceptionListener() throws javax.jms.JMSException
getExceptionListener
in interface javax.jms.Connection
javax.jms.IllegalStateException
- If the connection is closed.
javax.jms.JMSException
public void setClientID(java.lang.String clientID) throws javax.jms.JMSException
setClientID
in interface javax.jms.Connection
javax.jms.IllegalStateException
- Systematically thrown.
javax.jms.JMSException
public java.lang.String getClientID() throws javax.jms.JMSException
getClientID
in interface javax.jms.Connection
javax.jms.IllegalStateException
- If the connection is closed.
javax.jms.JMSException
public javax.jms.ConnectionMetaData getMetaData() throws javax.jms.JMSException
getMetaData
in interface javax.jms.Connection
javax.jms.IllegalStateException
- If the connection is closed.
javax.jms.JMSException
public void start() throws javax.jms.JMSException
start
in interface javax.jms.Connection
javax.jms.IllegalStateException
- If the connection is closed or broken.
javax.jms.JMSException
public void stop() throws javax.jms.JMSException
stop
in interface javax.jms.Connection
javax.jms.IllegalStateException
- If the connection is closed or broken.
javax.jms.JMSException
public void close() throws javax.jms.JMSException
close
in interface javax.jms.Connection
javax.jms.JMSException
- Actually never thrown.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |