@FunctionalInterface public interface ConsumerShutdownSignalCallback
Consumer for a lambda-oriented syntax,
if you don't need to implement all the application callbacks.CancelCallback,
DeliverCallback,
Channel.basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, CancelCallback),
Channel.basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, ConsumerShutdownSignalCallback),
Channel.basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)| Modifier and Type | Method and Description |
|---|---|
void |
handleShutdownSignal(String consumerTag,
ShutdownSignalException sig)
Called when either the channel or the underlying connection has been shut down.
|
void handleShutdownSignal(String consumerTag, ShutdownSignalException sig)
consumerTag - the consumer tag associated with the consumersig - a ShutdownSignalException indicating the reason for the shut downCopyright © 2021 VMware, Inc. or its affiliates.. All rights reserved.