|
Spring AMQP | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.amqp.rabbit.support.ConsumerChannelRegistry
public class ConsumerChannelRegistry
Consumers register their primary channels with this class. This is used to ensure that, when using transactions, the resource holder doesn't close the primary channel being used by the Consumer. This was previously in ConnectionFactoryUtils, but it caused a class tangle with RabbitResourceHolder.
| Constructor Summary | |
|---|---|
ConsumerChannelRegistry()
|
|
| Method Summary | |
|---|---|
static com.rabbitmq.client.Channel |
getConsumerChannel()
See registerConsumerChannel. |
static void |
registerConsumerChannel(com.rabbitmq.client.Channel channel)
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. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public ConsumerChannelRegistry()
| Method Detail |
|---|
public static void registerConsumerChannel(com.rabbitmq.client.Channel channel)
channel - public static void unRegisterConsumerChannel()
public static com.rabbitmq.client.Channel getConsumerChannel()
|
Spring AMQP | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||