@FunctionalInterface public interface DeliverCallback
Consumer for a lambda-oriented syntax,
if you don't need to implement all the application callbacks.CancelCallback,
ConsumerShutdownSignalCallback,
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 |
handle(String consumerTag,
Delivery message)
Called when a
basic.deliver is received for this consumer. |
void handle(String consumerTag, Delivery message) throws IOException
basic.deliver is received for this consumer.consumerTag - the consumer tag associated with the consumermessage - the delivered messageIOException - if the consumer encounters an I/O error while processing the messageCopyright © 2021 VMware, Inc. or its affiliates.. All rights reserved.