Package io.micronaut.rabbitmq.intercept

Interface DefaultConsumer

All Superinterfaces:
com.rabbitmq.client.Consumer
public interface DefaultConsumer extends com.rabbitmq.client.Consumer
A default Consumer that delegates cancelled or shutdown with a single method handleTerminate(String).
Since:
1.1.0
Author:
James Kleeh

  • Method Details

    • handleConsumeOk

      default void handleConsumeOk(String consumerTag)
      Specified by:
      handleConsumeOk in interface com.rabbitmq.client.Consumer

    • handleCancelOk

      default void handleCancelOk(String consumerTag)
      Specified by:
      handleCancelOk in interface com.rabbitmq.client.Consumer

    • handleCancel

      default void handleCancel(String consumerTag) throws IOException
      Specified by:
      handleCancel in interface com.rabbitmq.client.Consumer
      Throws:
      IOException

    • handleShutdownSignal

      default void handleShutdownSignal(String consumerTag, com.rabbitmq.client.ShutdownSignalException sig)
      Specified by:
      handleShutdownSignal in interface com.rabbitmq.client.Consumer

    • handleRecoverOk

      default void handleRecoverOk(String consumerTag)
      Specified by:
      handleRecoverOk in interface com.rabbitmq.client.Consumer

    • handleTerminate

      default void handleTerminate(String consumerTag)
      Called when a consumer is cancelled or shut down.
      Parameters:
      consumerTag - The consumer tag