io.micronaut.configuration.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 Summary

Modifier and Type	Method and Description
default void	handleCancel(String consumerTag)
default void	handleCancelOk(String consumerTag)
default void	handleConsumeOk(String consumerTag)
default void	handleRecoverOk(String consumerTag)
default void	handleShutdownSignal(String consumerTag, com.rabbitmq.client.ShutdownSignalException sig)
default void	handleTerminate(String consumerTag) Called when a consumer is cancelled or shut down.

Methods inherited from interface com.rabbitmq.client.Consumer

handleDelivery

Method Detail

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