java.lang.Object
org.activemq.pool.PooledConnectionFactory
- All Implemented Interfaces:
- javax.jms.ConnectionFactory, org.activemq.service.Service
- public class PooledConnectionFactory
- extends java.lang.Object
- implements javax.jms.ConnectionFactory, org.activemq.service.Service
- Version:
- $Revision: 1.1 $
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
connectionFactory
private org.activemq.ActiveMQConnectionFactory connectionFactory
cache
private java.util.Map cache
PooledConnectionFactory
public PooledConnectionFactory()
PooledConnectionFactory
public PooledConnectionFactory(java.lang.String brokerURL)
PooledConnectionFactory
public PooledConnectionFactory(org.activemq.ActiveMQConnectionFactory connectionFactory)
getConnectionFactory
public org.activemq.ActiveMQConnectionFactory getConnectionFactory()
setConnectionFactory
public void setConnectionFactory(org.activemq.ActiveMQConnectionFactory connectionFactory)
createConnection
public javax.jms.Connection createConnection()
throws javax.jms.JMSException
- Specified by:
createConnection in interface javax.jms.ConnectionFactory
createConnection
public javax.jms.Connection createConnection(java.lang.String userName,
java.lang.String password)
throws javax.jms.JMSException
- Specified by:
createConnection in interface javax.jms.ConnectionFactory
createConnection
protected org.activemq.ActiveMQConnection createConnection(ConnectionKey key)
throws javax.jms.JMSException
start
public void start()
throws javax.jms.JMSException
- Description copied from interface:
org.activemq.service.Service
- Called to start the service
- Specified by:
start in interface org.activemq.service.Service
stop
public void stop()
throws javax.jms.JMSException
- Description copied from interface:
org.activemq.service.Service
- Called to shutdown the service
- Specified by:
stop in interface org.activemq.service.Service