com.si.celery.broker.consumer

Class BasicRabbitMQConsumer

java.lang.Object

com.si.celery.broker.consumer.BasicRabbitMQConsumer

public class BasicRabbitMQConsumer
extends java.lang.Object

Basic Rabbit MQ Consumer

Constructor Summary

Constructors

Constructor and Description
BasicRabbitMQConsumer()

Method Summary

Modifier and Type	Method and Description
java.lang.String	basicConsume(java.lang.String queue, com.rabbitmq.client.Channel channel, com.rabbitmq.client.Consumer consumer) Perform a basic consumption with a given consumer.

Methods inherited from class java.lang.Object

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

Constructor Detail

BasicRabbitMQConsumer

public BasicRabbitMQConsumer()

Method Detail

basicConsume

public java.lang.String basicConsume(java.lang.String queue,
                                     com.rabbitmq.client.Channel channel,
                                     com.rabbitmq.client.Consumer consumer)
                              throws java.io.IOException

Perform a basic consumption with a given consumer.

Parameters:

queue - The queue

channel - The channel

consumer - The consumer

Returns:

result of consumption

Throws:

java.io.IOException