|
Joram ${version} | |||||||||
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.
Constructor Summary | |
Connection(FactoryParameters factoryParameters,
RequestChannel requestChannel)
Creates a Connection instance. |
Method Summary | |
protected void |
addSession(Session session)
Called here and by sub-classes. |
protected void |
checkClosed()
Checks if the connecion is closed. |
void |
cleanup()
Used by OutboundConnection in the connector layer. |
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. |
protected RequestMultiplexer |
getRequestMultiplexer()
|
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 |
Constructor Detail |
public Connection(FactoryParameters factoryParameters, RequestChannel requestChannel) throws javax.jms.JMSException
Connection
instance.
factoryParameters
- The factory parameters.
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.
protected void checkClosed() throws javax.jms.IllegalStateException
javax.jms.IllegalStateException
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.protected void addSession(Session session)
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.public void cleanup()
protected final RequestMultiplexer getRequestMultiplexer()
|
Joram ${version} | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |