public abstract class DefaultChannelListener extends Object implements ChannelListener
Constructor and Description |
---|
DefaultChannelListener() |
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. |
public void onCreate(com.rabbitmq.client.Channel channel)
ChannelListener
channel
is successfully created.onCreate
in interface ChannelListener
public void onCreateFailure(Throwable failure)
ChannelListener
onCreateFailure
in interface ChannelListener
public void onRecovery(com.rabbitmq.client.Channel channel)
ChannelListener
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.onRecovery
in interface ChannelListener
public void onRecoveryCompleted(com.rabbitmq.client.Channel channel)
ChannelListener
channel
and its consumers is completed. Note: The success
or failure of an individual consumer's recovery can be tracked with a ConsumerListener
.onRecoveryCompleted
in interface ChannelListener
public void onRecoveryFailure(com.rabbitmq.client.Channel channel, Throwable failure)
ChannelListener
channel
fails to recover from an unexpected closure.onRecoveryFailure
in interface ChannelListener
public void onRecoveryStarted(com.rabbitmq.client.Channel channel)
ChannelListener
channel
is started.onRecoveryStarted
in interface ChannelListener
Copyright © 2016. All rights reserved.