org.mule.transport.amqp.internal.endpoint.receiver
Class MessageReceiverConsumer

java.lang.Object
  extended by com.rabbitmq.client.DefaultConsumer
      extended by org.mule.transport.amqp.internal.endpoint.receiver.MessageReceiverConsumer
All Implemented Interfaces:
com.rabbitmq.client.Consumer

public final class MessageReceiverConsumer
extends com.rabbitmq.client.DefaultConsumer


Constructor Summary
MessageReceiverConsumer(MultiChannelMessageSubReceiver messageReceiver, com.rabbitmq.client.Channel channel)
           
 
Method Summary
protected  void deliverAmqpMessage(AmqpMessage amqpMessage)
           
 void handleCancel(String consumerTag)
           
 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
 

Constructor Detail

MessageReceiverConsumer

public MessageReceiverConsumer(MultiChannelMessageSubReceiver messageReceiver,
                               com.rabbitmq.client.Channel channel)
Method Detail

handleCancel

public void handleCancel(String consumerTag)
                  throws IOException
Specified by:
handleCancel in interface com.rabbitmq.client.Consumer
Overrides:
handleCancel 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

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

deliverAmqpMessage

protected void deliverAmqpMessage(AmqpMessage amqpMessage)


Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.