Package org.objectweb.joram.mom.dest.amqp

Class AmqpAcquisition.AmqpConsumer

java.lang.Object

com.rabbitmq.client.DefaultConsumer

org.objectweb.joram.mom.dest.amqp.AmqpAcquisition.AmqpConsumer

All Implemented Interfaces:

com.rabbitmq.client.Consumer

Enclosing class:

AmqpAcquisition

private class AmqpAcquisition.AmqpConsumer
extends com.rabbitmq.client.DefaultConsumer

Field Summary

Fields

Modifier and Type	Field	Description
private String	name

Constructor Summary

Constructors

Constructor	Description
AmqpConsumer(com.rabbitmq.client.Channel channel, String name)

Method Summary

Modifier and Type	Method	Description
void	handleDelivery(String consumerTag, com.rabbitmq.client.Envelope envelope, com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body)
void	handleShutdownSignal(String consumerTag, com.rabbitmq.client.ShutdownSignalException sig)

Methods inherited from class com.rabbitmq.client.DefaultConsumer

getChannel, getConsumerTag, handleCancelOk, handleConsumeOk, handleRecoverOk

Methods inherited from class java.lang.Object

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

Field Detail

name

private String name

Constructor Detail

AmqpConsumer

public AmqpConsumer(com.rabbitmq.client.Channel channel,
                    String name)

Method Detail

handleDelivery

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

Specified by:

handleDelivery in interface com.rabbitmq.client.Consumer

Overrides:

handleDelivery in class com.rabbitmq.client.DefaultConsumer

Throws:

IOException

handleShutdownSignal

public void handleShutdownSignal(String consumerTag,
                                 com.rabbitmq.client.ShutdownSignalException sig)

Specified by:

handleShutdownSignal in interface com.rabbitmq.client.Consumer

Overrides:

handleShutdownSignal in class com.rabbitmq.client.DefaultConsumer