org.springframework.amqp.rabbit.listener

Class SimpleMessageListenerContainer.AsyncMessageProcessingConsumer

java.lang.Object

org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.AsyncMessageProcessingConsumer

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

SimpleMessageListenerContainer

private class SimpleMessageListenerContainer.AsyncMessageProcessingConsumer
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
private BlockingQueueConsumer	consumer
private java.util.concurrent.CountDownLatch	start
private FatalListenerStartupException	startupException

Constructor Summary

Constructors

Constructor and Description
AsyncMessageProcessingConsumer(BlockingQueueConsumer consumer)

Method Summary

Modifier and Type	Method and Description
FatalListenerStartupException	getStartupException() Retrieve the fatal startup exception if this processor completely failed to locate the broker resources it needed.
private void	logConsumerException(java.lang.Throwable t)
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

consumer

private final BlockingQueueConsumer consumer

start

private final java.util.concurrent.CountDownLatch start

startupException

private volatile FatalListenerStartupException startupException

Constructor Detail

AsyncMessageProcessingConsumer

public AsyncMessageProcessingConsumer(BlockingQueueConsumer consumer)

Method Detail

getStartupException

public FatalListenerStartupException getStartupException()
                                                  throws java.util.concurrent.TimeoutException,
                                                         java.lang.InterruptedException

Retrieve the fatal startup exception if this processor completely failed to locate the broker resources it needed. Blocks up to 60 seconds waiting for an exception to occur (but should always return promptly in normal circumstances). No longer fatal if the processor does not start up in 60 seconds.

Returns:

a startup exception if there was one

Throws:

java.util.concurrent.TimeoutException - if the consumer hasn't started

java.lang.InterruptedException - if the consumer startup is interrupted

run

public void run()

Specified by:

run in interface java.lang.Runnable

logConsumerException

private void logConsumerException(java.lang.Throwable t)