public class PooledConnectionFactory extends Object implements javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory, Referenceable
Modifier and Type | Field and Description |
---|---|
static String |
JNDI_ADDRESS_CONNECTION_TIMEOUT |
static String |
JNDI_ADDRESS_MAX_POOL_SIZE |
Constructor and Description |
---|
PooledConnectionFactory() |
Modifier and Type | Method and Description |
---|---|
javax.jms.Connection |
createConnection() |
javax.jms.Connection |
createConnection(String userName,
String password) |
javax.jms.QueueConnection |
createQueueConnection() |
javax.jms.QueueConnection |
createQueueConnection(String userName,
String password) |
javax.jms.TopicConnection |
createTopicConnection() |
javax.jms.TopicConnection |
createTopicConnection(String userName,
String password) |
long |
getConnectionTimeout() |
ConnectionURL |
getConnectionURL() |
String |
getConnectionURLString() |
int |
getMaxPoolSize() |
Reference |
getReference() |
protected CommonConnection |
newConnectionInstance(ConnectionURL connectionDetails) |
void |
setConnectionTimeout(long timeout) |
void |
setConnectionURLString(String url) |
void |
setMaxPoolSize(int maxPoolSize) |
public static final String JNDI_ADDRESS_MAX_POOL_SIZE
public static final String JNDI_ADDRESS_CONNECTION_TIMEOUT
public javax.jms.QueueConnection createQueueConnection() throws javax.jms.JMSException
createQueueConnection
in interface javax.jms.QueueConnectionFactory
javax.jms.JMSException
public javax.jms.QueueConnection createQueueConnection(String userName, String password) throws javax.jms.JMSException
createQueueConnection
in interface javax.jms.QueueConnectionFactory
javax.jms.JMSException
public javax.jms.TopicConnection createTopicConnection() throws javax.jms.JMSException
createTopicConnection
in interface javax.jms.TopicConnectionFactory
javax.jms.JMSException
public javax.jms.TopicConnection createTopicConnection(String userName, String password) throws javax.jms.JMSException
createTopicConnection
in interface javax.jms.TopicConnectionFactory
javax.jms.JMSException
public javax.jms.Connection createConnection() throws javax.jms.JMSException
createConnection
in interface javax.jms.ConnectionFactory
javax.jms.JMSException
public javax.jms.Connection createConnection(String userName, String password) throws javax.jms.JMSException
createConnection
in interface javax.jms.ConnectionFactory
javax.jms.JMSException
protected CommonConnection newConnectionInstance(ConnectionURL connectionDetails) throws QpidException
QpidException
public int getMaxPoolSize()
public long getConnectionTimeout()
public void setMaxPoolSize(int maxPoolSize)
public void setConnectionTimeout(long timeout)
public ConnectionURL getConnectionURL()
public String getConnectionURLString()
public final void setConnectionURLString(String url) throws URLSyntaxException
URLSyntaxException
public Reference getReference() throws NamingException
getReference
in interface Referenceable
NamingException
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.