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