Class ConsumerDispatcher

java.lang.Object

com.rabbitmq.client.impl.ConsumerDispatcher

final class ConsumerDispatcher
extends Object

Dispatches notifications to a Consumer on an internally-managed executor service and work pool.

Each Channel has a single ConsumerDispatcher, but the executor service and work pool may be shared with other channels, typically those on the same AMQConnection.

Field Summary

Fields

Modifier and Type	Field	Description
private final Channel	channel
private final AMQConnection	connection
private CountDownLatch	shutdownConsumersComplete
private boolean	shutdownConsumersDriven
private ShutdownSignalException	shutdownSignal
private boolean	shuttingDown
private final ConsumerWorkService	workService

Constructor Summary

Constructors

Constructor	Description
ConsumerDispatcher(AMQConnection connection, Channel channel, ConsumerWorkService workService)

Method Summary

Modifier and Type	Method	Description
private void	checkShutdown()
private void	execute(Runnable r)
private void	executeUnlessShuttingDown(Runnable r)
void	handleCancel(Consumer delegate, String consumerTag)
void	handleCancelOk(Consumer delegate, String consumerTag)
void	handleConsumeOk(Consumer delegate, String consumerTag)
void	handleDelivery(Consumer delegate, String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)
void	handleRecoverOk(Consumer delegate, String consumerTag)
CountDownLatch	handleShutdownSignal(Map<String,Consumer> consumers, ShutdownSignalException signal)
private void	notifyConsumerOfShutdown(String consumerTag, Consumer consumer, ShutdownSignalException signal)
private void	notifyConsumersOfShutdown(Map<String,Consumer> consumers, ShutdownSignalException signal)
void	quiesce()	Prepare for shutdown of all consumers on this channel
void	setUnlimited(boolean unlimited)
private void	shutdown(ShutdownSignalException signal)

Methods inherited from class Object

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

Field Details

workService

private final ConsumerWorkService workService

connection

private final AMQConnection connection

channel

private final Channel channel

shuttingDown

private volatile boolean shuttingDown

shutdownConsumersDriven

private volatile boolean shutdownConsumersDriven

shutdownConsumersComplete

private volatile CountDownLatch shutdownConsumersComplete

shutdownSignal

private volatile ShutdownSignalException shutdownSignal

Constructor Details

ConsumerDispatcher

public ConsumerDispatcher(AMQConnection connection,
 Channel channel,
 ConsumerWorkService workService)

Method Details

quiesce

public void quiesce()

Prepare for shutdown of all consumers on this channel

setUnlimited

public void setUnlimited(boolean unlimited)

handleConsumeOk

public void handleConsumeOk(Consumer delegate,
 String consumerTag)

handleCancelOk

public void handleCancelOk(Consumer delegate,
 String consumerTag)

handleCancel

public void handleCancel(Consumer delegate,
 String consumerTag)

handleRecoverOk

public void handleRecoverOk(Consumer delegate,
 String consumerTag)

handleDelivery

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

Throws:

IOException

handleShutdownSignal

public CountDownLatch handleShutdownSignal(Map<String,Consumer> consumers,
 ShutdownSignalException signal)

notifyConsumersOfShutdown

private void notifyConsumersOfShutdown(Map<String,Consumer> consumers,
 ShutdownSignalException signal)

notifyConsumerOfShutdown

private void notifyConsumerOfShutdown(String consumerTag,
 Consumer consumer,
 ShutdownSignalException signal)

executeUnlessShuttingDown

private void executeUnlessShuttingDown(Runnable r)

execute

private void execute(Runnable r)

shutdown

private void shutdown(ShutdownSignalException signal)

checkShutdown

private void checkShutdown()