Class PoolableChannelFactory
- java.lang.Object
-
- org.apache.camel.component.rabbitmq.pool.PoolableChannelFactory
-
- All Implemented Interfaces:
org.apache.commons.pool.PoolableObjectFactory<com.rabbitmq.client.Channel>
public class PoolableChannelFactory extends Object implements org.apache.commons.pool.PoolableObjectFactory<com.rabbitmq.client.Channel>
Channel lifecycle manager: create, check and close channel
-
-
Constructor Summary
Constructors Constructor Description PoolableChannelFactory(com.rabbitmq.client.Connection connection)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
activateObject(com.rabbitmq.client.Channel t)
void
destroyObject(com.rabbitmq.client.Channel t)
com.rabbitmq.client.Channel
makeObject()
void
passivateObject(com.rabbitmq.client.Channel t)
boolean
validateObject(com.rabbitmq.client.Channel t)
-
-
-
Method Detail
-
makeObject
public com.rabbitmq.client.Channel makeObject() throws Exception
- Specified by:
makeObject
in interfaceorg.apache.commons.pool.PoolableObjectFactory<com.rabbitmq.client.Channel>
- Throws:
Exception
-
destroyObject
public void destroyObject(com.rabbitmq.client.Channel t) throws Exception
- Specified by:
destroyObject
in interfaceorg.apache.commons.pool.PoolableObjectFactory<com.rabbitmq.client.Channel>
- Throws:
Exception
-
validateObject
public boolean validateObject(com.rabbitmq.client.Channel t)
- Specified by:
validateObject
in interfaceorg.apache.commons.pool.PoolableObjectFactory<com.rabbitmq.client.Channel>
-
activateObject
public void activateObject(com.rabbitmq.client.Channel t) throws Exception
- Specified by:
activateObject
in interfaceorg.apache.commons.pool.PoolableObjectFactory<com.rabbitmq.client.Channel>
- Throws:
Exception
-
-