public interface ConsumerListener
Consumer
related events.Modifier and Type | Method and Description |
---|---|
void |
onRecoveryCompleted(com.rabbitmq.client.Consumer consumer,
com.rabbitmq.client.Channel channel)
Called when recovery of the
consumer on the channel is successfully completed. |
void |
onRecoveryFailure(com.rabbitmq.client.Consumer consumer,
com.rabbitmq.client.Channel channel,
Throwable failure)
Called when the
consumer fails to recover from an unexpected closure on the
channel . |
void |
onRecoveryStarted(com.rabbitmq.client.Consumer consumer,
com.rabbitmq.client.Channel channel)
Called when recovery of the
consumer on the channel is started. |
void onRecoveryStarted(com.rabbitmq.client.Consumer consumer, com.rabbitmq.client.Channel channel)
consumer
on the channel
is started. 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.Consumer consumer, com.rabbitmq.client.Channel channel)
consumer
on the channel
is successfully completed.void onRecoveryFailure(com.rabbitmq.client.Consumer consumer, com.rabbitmq.client.Channel channel, Throwable failure)
consumer
fails to recover from an unexpected closure on the
channel
.Copyright © 2016. All rights reserved.