public class ConsumerChannelRegistry extends Object
Constructor and Description |
---|
ConsumerChannelRegistry() |
Modifier and Type | Method and Description |
---|---|
static com.rabbitmq.client.Channel |
getConsumerChannel()
See registerConsumerChannel.
|
static com.rabbitmq.client.Channel |
getConsumerChannel(ConnectionFactory connectionFactory)
See registerConsumerChannel.
|
static void |
registerConsumerChannel(com.rabbitmq.client.Channel channel,
ConnectionFactory connectionFactory)
If a listener container is configured to use a RabbitTransactionManager, the
consumer's channel is registered here so that it is used as the bound resource
when the transaction actually starts.
|
static void |
unRegisterConsumerChannel()
See registerConsumerChannel.
|
public static void registerConsumerChannel(com.rabbitmq.client.Channel channel, ConnectionFactory connectionFactory)
channel
- public static void unRegisterConsumerChannel()
public static com.rabbitmq.client.Channel getConsumerChannel()
public static com.rabbitmq.client.Channel getConsumerChannel(ConnectionFactory connectionFactory)
connectionFactory
- The connection factory.