org.aksw.iguana.rp.utils

Class DefaultReturnConsumer

java.lang.Object

com.rabbitmq.client.DefaultConsumer

org.aksw.iguana.rp.utils.DefaultReturnConsumer

All Implemented Interfaces:

com.rabbitmq.client.Consumer

public class DefaultReturnConsumer
extends com.rabbitmq.client.DefaultConsumer

Test consumer which returns the received Property

Author:

f.conrads

Constructor Summary

Constructors

Constructor and Description
DefaultReturnConsumer(com.rabbitmq.client.Channel channel) Constructs a new instance and records its association to the passed-in channel.

Method Summary

Modifier and Type	Method and Description
java.util.Properties	getReceivedProps()
void	handleDelivery(java.lang.String consumerTag, com.rabbitmq.client.Envelope envelope, com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body)
void	setReceivedProps(java.util.Properties receivedProps)

Methods inherited from class com.rabbitmq.client.DefaultConsumer

getChannel, getConsumerTag, handleCancel, handleCancelOk, handleConsumeOk, handleRecoverOk, handleShutdownSignal

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultReturnConsumer

public DefaultReturnConsumer(com.rabbitmq.client.Channel channel)

Constructs a new instance and records its association to the passed-in channel.

Parameters:

channel -

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

Specified by:

handleDelivery in interface com.rabbitmq.client.Consumer

Overrides:

handleDelivery in class com.rabbitmq.client.DefaultConsumer

Throws:

java.io.IOException

getReceivedProps

public java.util.Properties getReceivedProps()

Returns:

the receivedProps

setReceivedProps

public void setReceivedProps(java.util.Properties receivedProps)

Parameters:

receivedProps - the receivedProps to set