@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 © 2022 VMware, Inc. or its affiliates.. All rights reserved.