Package com.rabbitmq.client.impl

Class ForgivingExceptionHandler

java.lang.Object
com.rabbitmq.client.impl.ForgivingExceptionHandler
All Implemented Interfaces:
ExceptionHandler
Direct Known Subclasses:
StrictExceptionHandler
public class ForgivingExceptionHandler extends Object implements ExceptionHandler
An implementation of ExceptionHandler that does not close channels on unhandled consumer and listener exception. Used by AMQConnection.
See Also:

  • Constructor Details

    • ForgivingExceptionHandler

      public ForgivingExceptionHandler()

  • Method Details

    • handleUnexpectedConnectionDriverException

      public void handleUnexpectedConnectionDriverException(Connection conn, Throwable exception)
      Description copied from interface: ExceptionHandler
      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.
      Specified by:
      handleUnexpectedConnectionDriverException in interface ExceptionHandler
      Parameters:
      conn - the Connection that caught the exception
      exception - the exception caught in the driver thread

    • 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
      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
      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
      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
      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

    • handleConnectionRecoveryException

      public void handleConnectionRecoveryException(Connection conn, Throwable exception)
      Description copied from interface: ExceptionHandler
      Perform any required exception processing for the situation when the driver thread for the connection has an exception during connection recovery that it can't otherwise deal with.
      Specified by:
      handleConnectionRecoveryException in interface ExceptionHandler
      Parameters:
      conn - the Connection that caught the exception
      exception - the exception caught in the driver thread
      Since:
      3.3.0

    • handleChannelRecoveryException

      public void handleChannelRecoveryException(Channel ch, Throwable exception)
      Description copied from interface: ExceptionHandler
      Perform any required exception processing for the situation when the driver thread for the connection has an exception during channel recovery that it can't otherwise deal with.
      Specified by:
      handleChannelRecoveryException in interface ExceptionHandler
      Parameters:
      ch - the Channel that caught the exception
      exception - the exception caught in the driver thread
      Since:
      3.3.0

    • handleTopologyRecoveryException

      public void handleTopologyRecoveryException(Connection conn, Channel ch, TopologyRecoveryException exception)
      Description copied from interface: ExceptionHandler
      Perform any required exception processing for the situation when the driver thread for the connection has an exception during topology (exchanges, queues, bindings, consumers) recovery that it can't otherwise deal with.
      Specified by:
      handleTopologyRecoveryException in interface ExceptionHandler
      Parameters:
      conn - the Connection that caught the exception
      ch - the Channel that caught the exception. May be null.
      exception - the exception caught in the driver thread
      Since:
      3.3.0

    • handleChannelKiller

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

    • handleConnectionKiller

      protected void handleConnectionKiller(Connection connection, Throwable exception, String what)

    • log

      protected void log(String message, Throwable e)