Package net.jodah.lyra.event

Interface ConsumerListener

All Known Implementing Classes:
DefaultConsumerListener
public interface ConsumerListener
Listens for Consumer related events.

  • Method Summary

    Modifier and Type Method 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, java.lang.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.

  • Method Details

    • onRecoveryStarted

      void onRecoveryStarted​(com.rabbitmq.client.Consumer consumer, com.rabbitmq.client.Channel channel)
      Called when recovery of the 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.

    • onRecoveryCompleted

      void onRecoveryCompleted​(com.rabbitmq.client.Consumer consumer, com.rabbitmq.client.Channel channel)
      Called when recovery of the consumer on the channel is successfully completed.

    • onRecoveryFailure

      void onRecoveryFailure​(com.rabbitmq.client.Consumer consumer, com.rabbitmq.client.Channel channel, java.lang.Throwable failure)
      Called when the consumer fails to recover from an unexpected closure on the channel.