open class DelegatingConnectionFactory : SmartConnectionFactory, QueueConnectionFactory, TopicConnectionFactory, InitializingBean
javax.jms.ConnectionFactory implementation that delegates all calls to a given target javax.jms.ConnectionFactory, adapting specific create(Queue/Topic)Connection calls to the target ConnectionFactory if necessary (e.g. when running JMS 1.0.2 API based code against a generic JMS 1.1 ConnectionFactory, such as ActiveMQ's PooledConnectionFactory).
This class allows for being subclassed, with subclasses overriding only those methods (such as #createConnection()) that should not simply delegate to the target ConnectionFactory.
Can also be defined as-is, wrapping a specific target ConnectionFactory, using the "shouldStopConnections" flag to indicate whether Connections obtained from the target factory are supposed to be stopped before closed. The latter may be necessary for some connection pools that simply return released connections to the pool, not stopping them while they sit in the pool.
Author
Juergen Hoeller
Since
2.0.2
See Also
#createConnection()#setShouldStopConnectionsConnectionFactoryUtils#releaseConnection
DelegatingConnectionFactory()
javax.jms.ConnectionFactory implementation that delegates all calls to a given target javax.jms.ConnectionFactory, adapting specific This class allows for being subclassed, with subclasses overriding only those methods (such as Can also be defined as-is, wrapping a specific target ConnectionFactory, using the "shouldStopConnections" flag to indicate whether Connections obtained from the target factory are supposed to be stopped before closed. The latter may be necessary for some connection pools that simply return released connections to the pool, not stopping them while they sit in the pool. |
open fun afterPropertiesSet(): Unit |
|
open fun createConnection(): Connectionopen fun createConnection(username: String, password: String): Connection |
|
open fun createContext(): JMSContextopen fun createContext(userName: String, password: String): JMSContextopen fun createContext(userName: String, password: String, sessionMode: Int): JMSContextopen fun createContext(sessionMode: Int): JMSContext |
|
open fun createQueueConnection(): QueueConnectionopen fun createQueueConnection(username: String, password: String): QueueConnection |
|
open fun createTopicConnection(): TopicConnectionopen fun createTopicConnection(username: String, password: String): TopicConnection |
|
open fun getTargetConnectionFactory(): ConnectionFactory
Return the target ConnectionFactory that this ConnectionFactory delegates to. |
|
open fun setShouldStopConnections(shouldStopConnections: Boolean): Unit
Indicate whether Connections obtained from the target factory are supposed to be stopped before closed ("true") or simply closed ("false"). An extra stop call may be necessary for some connection pools that simply return released connections to the pool, not stopping them while they sit in the pool. Default is "false", simply closing Connections. |
|
open fun setTargetConnectionFactory(targetConnectionFactory: ConnectionFactory): Unit
Set the target ConnectionFactory that this ConnectionFactory should delegate to. |
|
open fun shouldStop(con: Connection): Boolean |