com.si.celery.backend.rabbit

Class RabbitBackendConsumer

java.lang.Object

com.rabbitmq.client.DefaultConsumer

com.si.celery.backend.rabbit.RabbitBackendConsumer

All Implemented Interfaces:

com.rabbitmq.client.Consumer

public class RabbitBackendConsumer
extends com.rabbitmq.client.DefaultConsumer

Extension of the default consumer

Constructor Summary

Constructors

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.

Method Summary

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.

Methods inherited from class com.rabbitmq.client.DefaultConsumer

getChannel, getConsumerTag, handleCancelOk, handleConsumeOk, handleRecoverOk, handleShutdownSignal

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RabbitBackendConsumer

public 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.

Parameters:

channel - the channel to which this consumer is attached

Method Detail

handleDelivery

public void handleDelivery(java.lang.String consumerTag,
                           com.rabbitmq.client.Envelope envelope,
                           com.rabbitmq.client.AMQP.BasicProperties properties,
                           byte[] body)
                    throws java.io.IOException

Handle the delivery of a message.

Specified by:

handleDelivery in interface com.rabbitmq.client.Consumer

Overrides:

handleDelivery in class com.rabbitmq.client.DefaultConsumer

Parameters:

consumerTag - Consumer tag for the message

envelope - The envelope for the message

properties - Basic properties input

body - Message body

Throws:

java.io.IOException - Exception of failure to handle a delivery

handleCancel

public void handleCancel(java.lang.String consumerTag)
                  throws java.io.IOException

Handle a cancel event

Specified by:

handleCancel in interface com.rabbitmq.client.Consumer

Overrides:

handleCancel in class com.rabbitmq.client.DefaultConsumer

Parameters:

consumerTag - The consumer tag

Throws:

java.io.IOException - Thrown on failure to cancel