public class SessionPool extends java.lang.Object implements org.apache.commons.pool.PoolableObjectFactory
Constructor and Description |
---|
SessionPool(ConnectionPool connectionPool,
SessionKey key,
org.apache.commons.pool.ObjectPool sessionPool) |
Modifier and Type | Method and Description |
---|---|
void |
activateObject(java.lang.Object o) |
PooledSession |
borrowSession() |
void |
close() |
protected ActiveMQSession |
createSession() |
void |
destroyObject(java.lang.Object o) |
protected ActiveMQConnection |
getConnection() |
protected org.apache.commons.pool.ObjectPool |
getSessionPool() |
void |
invalidateSession(PooledSession session) |
java.lang.Object |
makeObject() |
void |
passivateObject(java.lang.Object o) |
void |
returnSession(PooledSession session) |
boolean |
validateObject(java.lang.Object o) |
public SessionPool(ConnectionPool connectionPool, SessionKey key, org.apache.commons.pool.ObjectPool sessionPool)
public void close() throws java.lang.Exception
java.lang.Exception
public PooledSession borrowSession() throws javax.jms.JMSException
javax.jms.JMSException
public void returnSession(PooledSession session) throws javax.jms.JMSException
javax.jms.JMSException
public void invalidateSession(PooledSession session) throws javax.jms.JMSException
javax.jms.JMSException
public java.lang.Object makeObject() throws java.lang.Exception
makeObject
in interface org.apache.commons.pool.PoolableObjectFactory
java.lang.Exception
public void destroyObject(java.lang.Object o) throws java.lang.Exception
destroyObject
in interface org.apache.commons.pool.PoolableObjectFactory
java.lang.Exception
public boolean validateObject(java.lang.Object o)
validateObject
in interface org.apache.commons.pool.PoolableObjectFactory
public void activateObject(java.lang.Object o) throws java.lang.Exception
activateObject
in interface org.apache.commons.pool.PoolableObjectFactory
java.lang.Exception
public void passivateObject(java.lang.Object o) throws java.lang.Exception
passivateObject
in interface org.apache.commons.pool.PoolableObjectFactory
java.lang.Exception
protected org.apache.commons.pool.ObjectPool getSessionPool() throws AlreadyClosedException
AlreadyClosedException
protected ActiveMQConnection getConnection() throws javax.jms.JMSException
javax.jms.JMSException
protected ActiveMQSession createSession() throws javax.jms.JMSException
javax.jms.JMSException
Copyright © 2005-2017. All Rights Reserved.