Class ForgivingExceptionHandler

    • Constructor Detail

      • ForgivingExceptionHandler

        public ForgivingExceptionHandler()
    • Method Detail

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