Package net.jodah.lyra.event

Class DefaultConsumerListener

java.lang.Object
net.jodah.lyra.event.DefaultConsumerListener
All Implemented Interfaces:
ConsumerListener
public abstract class DefaultConsumerListener
extends java.lang.Object
implements ConsumerListener
No-op consumer listener for sub-classing.

  • Constructor Summary

    Constructors 
    Constructor Description
    DefaultConsumerListener()  

  • 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.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

  • Method Details

    • onRecoveryCompleted

      public void onRecoveryCompleted​(com.rabbitmq.client.Consumer consumer, com.rabbitmq.client.Channel channel)
      Description copied from interface: ConsumerListener
      Called when recovery of the consumer on the channel is successfully completed.
      Specified by:
      onRecoveryCompleted in interface ConsumerListener

    • onRecoveryFailure

      public void onRecoveryFailure​(com.rabbitmq.client.Consumer consumer, com.rabbitmq.client.Channel channel, java.lang.Throwable failure)
      Description copied from interface: ConsumerListener
      Called when the consumer fails to recover from an unexpected closure on the channel.
      Specified by:
      onRecoveryFailure in interface ConsumerListener

    • onRecoveryStarted

      public void onRecoveryStarted​(com.rabbitmq.client.Consumer consumer, com.rabbitmq.client.Channel channel)
      Description copied from interface: ConsumerListener
      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.
      Specified by:
      onRecoveryStarted in interface ConsumerListener