public abstract class DefaultConsumerListener extends Object implements ConsumerListener
Constructor and Description |
---|
DefaultConsumerListener() |
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. |
public void onRecoveryCompleted(com.rabbitmq.client.Consumer consumer, com.rabbitmq.client.Channel channel)
ConsumerListener
consumer
on the channel
is successfully completed.onRecoveryCompleted
in interface ConsumerListener
public void onRecoveryFailure(com.rabbitmq.client.Consumer consumer, com.rabbitmq.client.Channel channel, Throwable failure)
ConsumerListener
consumer
fails to recover from an unexpected closure on the
channel
.onRecoveryFailure
in interface ConsumerListener
public void onRecoveryStarted(com.rabbitmq.client.Consumer consumer, com.rabbitmq.client.Channel channel)
ConsumerListener
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.onRecoveryStarted
in interface ConsumerListener
Copyright © 2016. All rights reserved.