public class RabbitBackendConsumer
extends com.rabbitmq.client.DefaultConsumer
| Constructor and Description |
|---|
RabbitBackendConsumer(com.rabbitmq.client.Channel channel,
com.google.common.util.concurrent.SettableFuture<java.lang.String> fut,
java.lang.String acceptContent)
Constructs a new instance and records its association to the passed-in channel.
|
| Modifier and Type | Method and Description |
|---|---|
void |
handleCancel(java.lang.String consumerTag)
Handle a cancel event
|
void |
handleDelivery(java.lang.String consumerTag,
com.rabbitmq.client.Envelope envelope,
com.rabbitmq.client.AMQP.BasicProperties properties,
byte[] body)
Handle the delivery of a message.
|
public RabbitBackendConsumer(com.rabbitmq.client.Channel channel,
com.google.common.util.concurrent.SettableFuture<java.lang.String> fut,
java.lang.String acceptContent)
channel - the channel to which this consumer is attachedpublic void handleDelivery(java.lang.String consumerTag,
com.rabbitmq.client.Envelope envelope,
com.rabbitmq.client.AMQP.BasicProperties properties,
byte[] body)
throws java.io.IOException
handleDelivery in interface com.rabbitmq.client.ConsumerhandleDelivery in class com.rabbitmq.client.DefaultConsumerconsumerTag - Consumer tag for the messageenvelope - The envelope for the messageproperties - Basic properties inputbody - Message bodyjava.io.IOException - Exception of failure to handle a deliverypublic void handleCancel(java.lang.String consumerTag)
throws java.io.IOException
handleCancel in interface com.rabbitmq.client.ConsumerhandleCancel in class com.rabbitmq.client.DefaultConsumerconsumerTag - The consumer tagjava.io.IOException - Thrown on failure to cancel