public class

DefaultExceptionHandler

extends Object
implements ExceptionHandler
java.lang.Object
   ↳ com.rabbitmq.client.impl.DefaultExceptionHandler

Summary

Public Constructors
DefaultExceptionHandler()
Public Methods
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 handleFlowListenerException(Channel channel, Throwable exception)
Perform any required exception processing for the situation when the driver thread for the connection has called a FlowListener's handleFlow method, and that method has thrown an exeption.
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.
void handleUnexpectedConnectionDriverException(Connection conn, Throwable exception)
Perform any required exception processing for the situation when the driver thread for the connection has an exception signalled to it that it can't otherwise deal with.
Protected Methods
void handleChannelKiller(Channel channel, Throwable exception, String what)
[Expand]
Inherited Methods
From class java.lang.Object
From interface com.rabbitmq.client.impl.ExceptionHandler

Public Constructors

public DefaultExceptionHandler ()

Public Methods

public 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.

Parameters
channel the ChannelN that held the ConfirmListener
exception the exception thrown by ConfirmListener.handleAck

public 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.

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

public void handleFlowListenerException (Channel channel, Throwable exception)

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

Parameters
channel the ChannelN that held the FlowListener
exception the exception thrown by FlowListener.handleFlow

public 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.

Parameters
channel the ChannelN that held the ReturnListener
exception the exception thrown by ReturnListener.handleReturn

public void handleUnexpectedConnectionDriverException (Connection conn, Throwable exception)

Perform any required exception processing for the situation when the driver thread for the connection has an exception signalled to it that it can't otherwise deal with.

Parameters
conn the Connection that caught the exception
exception the exception caught in the driver thread

Protected Methods

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