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.

Constructor Summary

Constructors

Constructor and Description
ConnectionPool(ActiveMQConnection connection, java.util.concurrent.ConcurrentHashMap<SessionKey,SessionPool> cache, org.apache.commons.pool.ObjectPoolFactory poolFactory)
ConnectionPool(ActiveMQConnection connection, org.apache.commons.pool.ObjectPoolFactory poolFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
javax.jms.Session	createSession(boolean transacted, int ackMode)
protected SessionPool	createSessionPool(SessionKey key)
void	decrementReferenceCount()
boolean	expiredCheck()
ActiveMQConnection	getConnection()
long	getExpiryTimeout()
int	getIdleTimeout()
void	incrementReferenceCount()
void	setExpiryTimeout(long expiryTimeout)
void	setIdleTimeout(int idleTimeout)
void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConnectionPool

public ConnectionPool(ActiveMQConnection connection,
              org.apache.commons.pool.ObjectPoolFactory poolFactory)

ConnectionPool

public ConnectionPool(ActiveMQConnection connection,
              java.util.concurrent.ConcurrentHashMap<SessionKey,SessionPool> cache,
              org.apache.commons.pool.ObjectPoolFactory poolFactory)

Method Detail

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()