public interface ChannelListener
Channel
related events.Modifier and Type | Method and Description |
---|---|
void |
onCreate(com.rabbitmq.client.Channel channel)
Called when the
channel is successfully created. |
void |
onCreateFailure(Throwable failure)
Called when channel creation fails.
|
void |
onRecovery(com.rabbitmq.client.Channel channel)
Called when the
channel is successfully recovered from an unexpected closure but before
its consumers and their associated queues, exchanges, and bindings are recovered. |
void |
onRecoveryCompleted(com.rabbitmq.client.Channel channel)
Called when recovery of the
channel and its consumers is completed. |
void |
onRecoveryFailure(com.rabbitmq.client.Channel channel,
Throwable failure)
Called when the
channel fails to recover from an unexpected closure. |
void |
onRecoveryStarted(com.rabbitmq.client.Channel channel)
Called when recovery of the
channel is started. |
void onCreate(com.rabbitmq.client.Channel channel)
channel
is successfully created.void onCreateFailure(Throwable failure)
void onRecoveryStarted(com.rabbitmq.client.Channel channel)
channel
is started.void onRecovery(com.rabbitmq.client.Channel channel)
channel
is successfully recovered from an unexpected closure but before
its consumers and their associated queues, exchanges, and bindings are recovered. This is
useful for performing any pre-consumer setup that is required such as declaring exchanges and
queues, and creating queue to exchange bindings.void onRecoveryCompleted(com.rabbitmq.client.Channel channel)
channel
and its consumers is completed. Note: The success
or failure of an individual consumer's recovery can be tracked with a ConsumerListener
.void onRecoveryFailure(com.rabbitmq.client.Channel channel, Throwable failure)
channel
fails to recover from an unexpected closure.Copyright © 2016. All rights reserved.