public class PooledConnection extends Object implements jakarta.jms.Connection
Modifier and Type | Field and Description |
---|---|
(package private) Connection |
delegate
The underlying connection to Joram's server
|
(package private) String |
name
The identity of the authentified user for this connection
|
(package private) String |
password
The identity of the authentified user for this connection
|
(package private) PooledConnectionFactory |
pcf
The pooled ConnectionFactory
|
Constructor and Description |
---|
PooledConnection(PooledConnectionFactory pcf,
String name,
String password)
Creates a new pooled connection.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the pooled connection, depending of the pool state this can results
in the real closing of the connection of the inserting in the pool of idle
connections.
|
jakarta.jms.ConnectionConsumer |
createConnectionConsumer(jakarta.jms.Destination dest,
String selector,
jakarta.jms.ServerSessionPool sessionPool,
int maxMessages) |
jakarta.jms.ConnectionConsumer |
createDurableConnectionConsumer(jakarta.jms.Topic topic,
String subName,
String selector,
jakarta.jms.ServerSessionPool sessPool,
int maxMessages) |
jakarta.jms.Session |
createSession() |
jakarta.jms.Session |
createSession(boolean transacted,
int acknowledgeMode) |
jakarta.jms.Session |
createSession(int sessionMode) |
jakarta.jms.ConnectionConsumer |
createSharedConnectionConsumer(jakarta.jms.Topic topic,
String subscriptionName,
String messageSelector,
jakarta.jms.ServerSessionPool sessionPool,
int maxMessages) |
jakarta.jms.ConnectionConsumer |
createSharedDurableConnectionConsumer(jakarta.jms.Topic topic,
String subscriptionName,
String messageSelector,
jakarta.jms.ServerSessionPool sessionPool,
int maxMessages) |
String |
getClientID() |
jakarta.jms.ExceptionListener |
getExceptionListener() |
jakarta.jms.ConnectionMetaData |
getMetaData() |
void |
setClientID(String clientID) |
void |
setExceptionListener(jakarta.jms.ExceptionListener listener) |
void |
start() |
void |
stop() |
String |
toString() |
PooledConnectionFactory pcf
Connection delegate
String name
String password
public PooledConnection(PooledConnectionFactory pcf, String name, String password) throws jakarta.jms.JMSException
pcf
- The pooled ConnectionFactory.name
- The name of the authentified user for this connection.password
- The password of the authentified user for this connection.jakarta.jms.JMSException
- An error occurs during the connection.public void close() throws jakarta.jms.JMSException
close
in interface jakarta.jms.Connection
close
in interface AutoCloseable
jakarta.jms.JMSException
Connection.close()
public jakarta.jms.ConnectionConsumer createConnectionConsumer(jakarta.jms.Destination dest, String selector, jakarta.jms.ServerSessionPool sessionPool, int maxMessages) throws jakarta.jms.JMSException
createConnectionConsumer
in interface jakarta.jms.Connection
jakarta.jms.JMSException
Connection.createConnectionConsumer(jakarta.jms.Destination, java.lang.String, jakarta.jms.ServerSessionPool, int)
public jakarta.jms.ConnectionConsumer createDurableConnectionConsumer(jakarta.jms.Topic topic, String subName, String selector, jakarta.jms.ServerSessionPool sessPool, int maxMessages) throws jakarta.jms.JMSException
createDurableConnectionConsumer
in interface jakarta.jms.Connection
jakarta.jms.JMSException
Connection.createDurableConnectionConsumer(jakarta.jms.Topic, java.lang.String, java.lang.String, jakarta.jms.ServerSessionPool, int)
public jakarta.jms.Session createSession(boolean transacted, int acknowledgeMode) throws jakarta.jms.JMSException
createSession
in interface jakarta.jms.Connection
jakarta.jms.JMSException
Connection.createSession(boolean, int)
public String getClientID() throws jakarta.jms.JMSException
getClientID
in interface jakarta.jms.Connection
jakarta.jms.JMSException
Connection.getClientID()
public jakarta.jms.ExceptionListener getExceptionListener() throws jakarta.jms.JMSException
getExceptionListener
in interface jakarta.jms.Connection
jakarta.jms.JMSException
Connection.getExceptionListener()
public jakarta.jms.ConnectionMetaData getMetaData() throws jakarta.jms.JMSException
getMetaData
in interface jakarta.jms.Connection
jakarta.jms.JMSException
Connection.getMetaData()
public void setClientID(String clientID) throws jakarta.jms.JMSException
setClientID
in interface jakarta.jms.Connection
jakarta.jms.JMSException
Connection.setClientID(java.lang.String)
public void setExceptionListener(jakarta.jms.ExceptionListener listener) throws jakarta.jms.JMSException
setExceptionListener
in interface jakarta.jms.Connection
jakarta.jms.JMSException
Connection.setExceptionListener(jakarta.jms.ExceptionListener)
public void start() throws jakarta.jms.JMSException
start
in interface jakarta.jms.Connection
jakarta.jms.JMSException
Connection.start()
public void stop() throws jakarta.jms.JMSException
stop
in interface jakarta.jms.Connection
jakarta.jms.JMSException
Connection.stop()
public String toString()
toString
in class Object
Object.toString()
public jakarta.jms.Session createSession(int sessionMode) throws jakarta.jms.JMSException
createSession
in interface jakarta.jms.Connection
jakarta.jms.JMSException
public jakarta.jms.Session createSession() throws jakarta.jms.JMSException
createSession
in interface jakarta.jms.Connection
jakarta.jms.JMSException
public jakarta.jms.ConnectionConsumer createSharedConnectionConsumer(jakarta.jms.Topic topic, String subscriptionName, String messageSelector, jakarta.jms.ServerSessionPool sessionPool, int maxMessages) throws jakarta.jms.JMSException
createSharedConnectionConsumer
in interface jakarta.jms.Connection
jakarta.jms.JMSException
public jakarta.jms.ConnectionConsumer createSharedDurableConnectionConsumer(jakarta.jms.Topic topic, String subscriptionName, String messageSelector, jakarta.jms.ServerSessionPool sessionPool, int maxMessages) throws jakarta.jms.JMSException
createSharedDurableConnectionConsumer
in interface jakarta.jms.Connection
jakarta.jms.JMSException
Copyright © 2022 ScalAgent D.T.. All rights reserved.