com.rabbitmq.client.impl

Class StrictExceptionHandler

java.lang.Object

com.rabbitmq.client.impl.ForgivingExceptionHandler

com.rabbitmq.client.impl.StrictExceptionHandler

All Implemented Interfaces:

ExceptionHandler

Direct Known Subclasses:

DefaultExceptionHandler

public class StrictExceptionHandler
extends ForgivingExceptionHandler
implements ExceptionHandler

An implementation of ExceptionHandler that does close channels on unhandled consumer exception. Used by AMQConnection.

See Also:

ExceptionHandler, ConnectionFactory.setExceptionHandler(ExceptionHandler)

Constructor Summary

Constructors

Constructor and Description
StrictExceptionHandler()

Method Summary

Modifier and Type	Method and Description
void	handleBlockedListenerException(Connection connection, Throwable exception) Perform any required exception processing for the situation when the driver thread for the connection has called a BlockedListener's method, and that method has thrown an exception.
protected void	handleChannelKiller(Channel channel, Throwable exception, String what)
protected void	handleChannelKiller(Channel channel, Throwable exception, String logMessage, String closeMessage)
void	handleConfirmListenerException(Channel channel, Throwable exception) Perform any required exception processing for the situation when the driver thread for the connection has called a ConfirmListener's handleAck or handleNack method, and that method has thrown an exception.
void	handleConsumerException(Channel channel, Throwable exception, Consumer consumer, String consumerTag, String methodName) Perform any required exception processing for the situation when the driver thread for the connection has called a method on a Consumer, and that method has thrown an exception.
void	handleReturnListenerException(Channel channel, Throwable exception) Perform any required exception processing for the situation when the driver thread for the connection has called a ReturnListener's handleReturn method, and that method has thrown an exception.

Methods inherited from class com.rabbitmq.client.impl.ForgivingExceptionHandler

handleChannelRecoveryException, handleConnectionKiller, handleConnectionRecoveryException, handleTopologyRecoveryException, handleUnexpectedConnectionDriverException, log

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.rabbitmq.client.ExceptionHandler

handleChannelRecoveryException, handleConnectionRecoveryException, handleTopologyRecoveryException, handleUnexpectedConnectionDriverException

Constructor Detail

StrictExceptionHandler

public StrictExceptionHandler()

Method Detail

handleReturnListenerException

public void handleReturnListenerException(Channel channel,
                                          Throwable exception)

Description copied from interface: ExceptionHandler

Perform any required exception processing for the situation when the driver thread for the connection has called a ReturnListener's handleReturn method, and that method has thrown an exception.

Specified by:

handleReturnListenerException in interface ExceptionHandler

Overrides:

handleReturnListenerException in class ForgivingExceptionHandler

Parameters:

channel - the ChannelN that held the ReturnListener

exception - the exception thrown by ReturnListener.handleReturn

handleConfirmListenerException

public void handleConfirmListenerException(Channel channel,
                                           Throwable exception)

Description copied from interface: ExceptionHandler

Perform any required exception processing for the situation when the driver thread for the connection has called a ConfirmListener's handleAck or handleNack method, and that method has thrown an exception.

Specified by:

handleConfirmListenerException in interface ExceptionHandler

Overrides:

handleConfirmListenerException in class ForgivingExceptionHandler

Parameters:

channel - the ChannelN that held the ConfirmListener

exception - the exception thrown by ConfirmListener.handleAck

handleBlockedListenerException

public void handleBlockedListenerException(Connection connection,
                                           Throwable exception)

Description copied from interface: ExceptionHandler

Perform any required exception processing for the situation when the driver thread for the connection has called a BlockedListener's method, and that method has thrown an exception.

Specified by:

handleBlockedListenerException in interface ExceptionHandler

Overrides:

handleBlockedListenerException in class ForgivingExceptionHandler

Parameters:

connection - the Connection that held the BlockedListener

exception - the exception thrown by the BlockedListener

handleConsumerException

public void handleConsumerException(Channel channel,
                                    Throwable exception,
                                    Consumer consumer,
                                    String consumerTag,
                                    String methodName)

Description copied from interface: ExceptionHandler

Perform any required exception processing for the situation when the driver thread for the connection has called a method on a Consumer, and that method has thrown an exception.

Specified by:

handleConsumerException in interface ExceptionHandler

Overrides:

handleConsumerException in class ForgivingExceptionHandler

Parameters:

channel - the ChannelN that held the Consumer

exception - the exception thrown by the Consumer

consumer - the Consumer that caused the fault

consumerTag - the Consumer's consumerTag

methodName - the name of the method on the Consumer that threw the exception

handleChannelKiller

protected void handleChannelKiller(Channel channel,
                                   Throwable exception,
                                   String what)

Overrides:

handleChannelKiller in class ForgivingExceptionHandler

handleChannelKiller

protected void handleChannelKiller(Channel channel,
                                   Throwable exception,
                                   String logMessage,
                                   String closeMessage)