org.apache.activemq.pool
Class ConnectionPool
java.lang.Object
org.apache.activemq.pool.ConnectionPool
- Direct Known Subclasses:
- XaConnectionPool
public class ConnectionPool
- extends java.lang.Object
Holds a real JMS connection along with the session pools associated with it.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ConnectionPool
public ConnectionPool(ActiveMQConnection connection,
org.apache.commons.pool.ObjectPoolFactory poolFactory)
ConnectionPool
public ConnectionPool(ActiveMQConnection connection,
java.util.Map<SessionKey,SessionPool> cache,
org.apache.commons.pool.ObjectPoolFactory poolFactory)
start
public void start()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getConnection
public ActiveMQConnection getConnection()
createSession
public javax.jms.Session createSession(boolean transacted,
int ackMode)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
close
public void close()
incrementReferenceCount
public void incrementReferenceCount()
decrementReferenceCount
public void decrementReferenceCount()
expiredCheck
public boolean expiredCheck()
- Returns:
- true if this connection has expired.
getIdleTimeout
public int getIdleTimeout()
setIdleTimeout
public void setIdleTimeout(int idleTimeout)
createSessionPool
protected SessionPool createSessionPool(SessionKey key)
setExpiryTimeout
public void setExpiryTimeout(long expiryTimeout)
getExpiryTimeout
public long getExpiryTimeout()
Copyright © 2005-2011. All Rights Reserved.