org.mule.transport.amqp.internal.endpoint.receiver
Class MessageReceiverConsumer
java.lang.Object
com.rabbitmq.client.DefaultConsumer
org.mule.transport.amqp.internal.endpoint.receiver.MessageReceiverConsumer
- All Implemented Interfaces:
- com.rabbitmq.client.Consumer
public final class MessageReceiverConsumer
- extends com.rabbitmq.client.DefaultConsumer
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 |
MessageReceiverConsumer
public MessageReceiverConsumer(MultiChannelMessageSubReceiver messageReceiver,
com.rabbitmq.client.Channel channel)
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.