public class ConnectionPool extends Object
Constructor and Description |
---|
ConnectionPool(ActiveMQConnection connection,
ConcurrentHashMap<SessionKey,SessionPool> cache,
org.apache.commons.pool.ObjectPoolFactory poolFactory) |
ConnectionPool(ActiveMQConnection connection,
org.apache.commons.pool.ObjectPoolFactory poolFactory) |
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() |
public ConnectionPool(ActiveMQConnection connection, org.apache.commons.pool.ObjectPoolFactory poolFactory)
public ConnectionPool(ActiveMQConnection connection, ConcurrentHashMap<SessionKey,SessionPool> cache, org.apache.commons.pool.ObjectPoolFactory poolFactory)
public void start() throws javax.jms.JMSException
javax.jms.JMSException
public ActiveMQConnection getConnection()
public javax.jms.Session createSession(boolean transacted, int ackMode) throws javax.jms.JMSException
javax.jms.JMSException
public void close()
public void incrementReferenceCount()
public void decrementReferenceCount()
public boolean expiredCheck()
public int getIdleTimeout()
public void setIdleTimeout(int idleTimeout)
protected SessionPool createSessionPool(SessionKey key)
public void setExpiryTimeout(long expiryTimeout)
public long getExpiryTimeout()
Copyright © 2005–2015. All rights reserved.