Package interlok.rabbitmq

Class AlwaysRestartExceptionHandler

java.lang.Object

com.adaptris.core.ConnectionErrorHandlerImp

interlok.rabbitmq.ExceptionHandlerImpl

interlok.rabbitmq.AlwaysRestartExceptionHandler

All Implemented Interfaces:

ComponentLifecycle, ConnectionErrorHandler, com.rabbitmq.client.ExceptionHandler

@ComponentProfile(summary="When RabbitMQ reports an exception, always restart",
                  recommended=RabbitMqConnection.class,
                  since="4.3.0")
public class AlwaysRestartExceptionHandler
extends ExceptionHandlerImpl

ConnectionErrorHandler implementation which always restarts whenever an error is encounted.

Field Summary

Fields inherited from class com.adaptris.core.ConnectionErrorHandlerImp

log

Constructor Summary

Constructors

Constructor	Description
AlwaysRestartExceptionHandler()

Method Summary

Modifier and Type	Method	Description
void	handleBlockedListenerException(com.rabbitmq.client.Connection c, java.lang.Throwable e)
void	handleChannelRecoveryException(com.rabbitmq.client.Channel ch, java.lang.Throwable exception)
void	handleConfirmListenerException(com.rabbitmq.client.Channel ch, java.lang.Throwable e)
void	handleConnectionRecoveryException(com.rabbitmq.client.Connection c, java.lang.Throwable e)
void	handleConsumerException(com.rabbitmq.client.Channel c, java.lang.Throwable e, com.rabbitmq.client.Consumer consumer, java.lang.String consumerTag, java.lang.String methodName)
void	handleReturnListenerException(com.rabbitmq.client.Channel ch, java.lang.Throwable e)
void	handleTopologyRecoveryException(com.rabbitmq.client.Connection c, com.rabbitmq.client.Channel ch, com.rabbitmq.client.TopologyRecoveryException e)
void	handleUnexpectedConnectionDriverException(com.rabbitmq.client.Connection c, java.lang.Throwable e)

Methods inherited from class interlok.rabbitmq.ExceptionHandlerImpl

handleConnectionException, registerConnection

Methods inherited from class com.adaptris.core.ConnectionErrorHandlerImp

allowedInConjunctionWith, getRegisteredChannels, restartAffectedComponents, retrieveConnection, retryWaitTimeMs

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.adaptris.core.ComponentLifecycle

close, init, start, stop

Constructor Detail

AlwaysRestartExceptionHandler

public AlwaysRestartExceptionHandler()

Method Detail

handleUnexpectedConnectionDriverException

public void handleUnexpectedConnectionDriverException(com.rabbitmq.client.Connection c,
                                                      java.lang.Throwable e)

handleReturnListenerException

public void handleReturnListenerException(com.rabbitmq.client.Channel ch,
                                          java.lang.Throwable e)

handleConfirmListenerException

public void handleConfirmListenerException(com.rabbitmq.client.Channel ch,
                                           java.lang.Throwable e)

handleBlockedListenerException

public void handleBlockedListenerException(com.rabbitmq.client.Connection c,
                                           java.lang.Throwable e)

handleConsumerException

public void handleConsumerException(com.rabbitmq.client.Channel c,
                                    java.lang.Throwable e,
                                    com.rabbitmq.client.Consumer consumer,
                                    java.lang.String consumerTag,
                                    java.lang.String methodName)

handleConnectionRecoveryException

public void handleConnectionRecoveryException(com.rabbitmq.client.Connection c,
                                              java.lang.Throwable e)

handleChannelRecoveryException

public void handleChannelRecoveryException(com.rabbitmq.client.Channel ch,
                                           java.lang.Throwable exception)

handleTopologyRecoveryException

public void handleTopologyRecoveryException(com.rabbitmq.client.Connection c,
                                            com.rabbitmq.client.Channel ch,
                                            com.rabbitmq.client.TopologyRecoveryException e)