org.springframework.amqp.rabbit.listener

Class BlockingQueueConsumer.InternalConsumer

java.lang.Object

com.rabbitmq.client.DefaultConsumer

org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.InternalConsumer

All Implemented Interfaces:

com.rabbitmq.client.Consumer

Enclosing class:

BlockingQueueConsumer

private class BlockingQueueConsumer.InternalConsumer
extends com.rabbitmq.client.DefaultConsumer

Constructor Summary

Constructors

Constructor and Description
InternalConsumer(com.rabbitmq.client.Channel channel)

Method Summary

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

Methods inherited from class com.rabbitmq.client.DefaultConsumer

getChannel, getConsumerTag, handleRecoverOk

Methods inherited from class java.lang.Object

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

Constructor Detail

InternalConsumer

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

Method Detail

handleConsumeOk

public void handleConsumeOk(java.lang.String consumerTag)

Specified by:

handleConsumeOk in interface com.rabbitmq.client.Consumer

Overrides:

handleConsumeOk in class com.rabbitmq.client.DefaultConsumer

handleShutdownSignal

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

Specified by:

handleShutdownSignal in interface com.rabbitmq.client.Consumer

Overrides:

handleShutdownSignal in class com.rabbitmq.client.DefaultConsumer

handleCancel

public void handleCancel(java.lang.String consumerTag)
                  throws java.io.IOException

Specified by:

handleCancel in interface com.rabbitmq.client.Consumer

Overrides:

handleCancel in class com.rabbitmq.client.DefaultConsumer

Throws:

java.io.IOException

handleCancelOk

public void handleCancelOk(java.lang.String consumerTag)

Specified by:

handleCancelOk in interface com.rabbitmq.client.Consumer

Overrides:

handleCancelOk in class com.rabbitmq.client.DefaultConsumer

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