org.objectweb.joram.client.jms.pool
Class PooledConnection
java.lang.Object
org.objectweb.joram.client.jms.pool.PooledConnection
- All Implemented Interfaces:
- javax.jms.Connection
public class PooledConnection
- extends java.lang.Object
- implements javax.jms.Connection
Implements a pooled connection.
Method Summary |
void |
close()
Close the pooled connection, depending of the pool state this can results
in the real closing of the connection of the inserting in the pool of idle
connections. |
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Destination dest,
java.lang.String selector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages)
|
javax.jms.ConnectionConsumer |
createDurableConnectionConsumer(javax.jms.Topic topic,
java.lang.String subName,
java.lang.String selector,
javax.jms.ServerSessionPool sessPool,
int maxMessages)
|
javax.jms.Session |
createSession(boolean transacted,
int acknowledgeMode)
|
java.lang.String |
getClientID()
|
javax.jms.ExceptionListener |
getExceptionListener()
|
javax.jms.ConnectionMetaData |
getMetaData()
|
void |
setClientID(java.lang.String clientID)
|
void |
setExceptionListener(javax.jms.ExceptionListener listener)
|
void |
start()
|
void |
stop()
|
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
PooledConnection
public PooledConnection(PooledConnectionFactory pcf,
java.lang.String name,
java.lang.String password)
throws javax.jms.JMSException
- Creates a new pooled connection.
- Parameters:
pcf
- The pooled ConnectionFactory.name
- The name of the authentified user for this connection.password
- The password of the authentified user for this connection.
- Throws:
javax.jms.JMSException
- An error occurs during the connection.
close
public void close()
throws javax.jms.JMSException
- Close the pooled connection, depending of the pool state this can results
in the real closing of the connection of the inserting in the pool of idle
connections.
- Specified by:
close
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
- See Also:
Connection.close()
createConnectionConsumer
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination dest,
java.lang.String selector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages)
throws javax.jms.JMSException
- Specified by:
createConnectionConsumer
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
- See Also:
Connection.createConnectionConsumer(javax.jms.Destination, java.lang.String, javax.jms.ServerSessionPool, int)
createDurableConnectionConsumer
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
- Specified by:
createDurableConnectionConsumer
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
- See Also:
Connection.createDurableConnectionConsumer(javax.jms.Topic, java.lang.String, java.lang.String, javax.jms.ServerSessionPool, int)
createSession
public javax.jms.Session createSession(boolean transacted,
int acknowledgeMode)
throws javax.jms.JMSException
- Specified by:
createSession
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
- See Also:
Connection.createSession(boolean, int)
getClientID
public java.lang.String getClientID()
throws javax.jms.JMSException
- Specified by:
getClientID
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
- See Also:
Connection.getClientID()
getExceptionListener
public javax.jms.ExceptionListener getExceptionListener()
throws javax.jms.JMSException
- Specified by:
getExceptionListener
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
- See Also:
Connection.getExceptionListener()
getMetaData
public javax.jms.ConnectionMetaData getMetaData()
throws javax.jms.JMSException
- Specified by:
getMetaData
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
- See Also:
Connection.getMetaData()
setClientID
public void setClientID(java.lang.String clientID)
throws javax.jms.JMSException
- Specified by:
setClientID
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
- See Also:
Connection.setClientID(java.lang.String)
setExceptionListener
public void setExceptionListener(javax.jms.ExceptionListener listener)
throws javax.jms.JMSException
- Specified by:
setExceptionListener
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
- See Also:
Connection.setExceptionListener(javax.jms.ExceptionListener)
start
public void start()
throws javax.jms.JMSException
- Specified by:
start
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
- See Also:
Connection.start()
stop
public void stop()
throws javax.jms.JMSException
- Specified by:
stop
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
- See Also:
Connection.stop()
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
- See Also:
Object.toString()
Copyright © 2011 ScalAgent D.T.. All Rights Reserved.