Package com.lmax.disruptor.dsl

Class ExceptionHandlerWrapper<T>

java.lang.Object

com.lmax.disruptor.dsl.ExceptionHandlerWrapper<T>

All Implemented Interfaces:

ExceptionHandler<T>

public class ExceptionHandlerWrapper<T>
extends java.lang.Object
implements ExceptionHandler<T>

Field Summary

Fields

Modifier and Type	Field	Description
private ExceptionHandler<? super T>	delegate

Constructor Summary

Constructors

Constructor	Description
ExceptionHandlerWrapper()

Method Summary

Modifier and Type	Method	Description
private ExceptionHandler<? super T>	getExceptionHandler()
void	handleEventException(java.lang.Throwable ex, long sequence, T event)	Strategy for handling uncaught exceptions when processing an event.
void	handleOnShutdownException(java.lang.Throwable ex)	Callback to notify of an exception during LifecycleAware.onShutdown()
void	handleOnStartException(java.lang.Throwable ex)	Callback to notify of an exception during LifecycleAware.onStart()
void	switchTo(ExceptionHandler<? super T> exceptionHandler)

Methods inherited from class java.lang.Object

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

Field Detail

delegate

private ExceptionHandler<? super T> delegate

Constructor Detail

ExceptionHandlerWrapper

public ExceptionHandlerWrapper()

Method Detail

switchTo

public void switchTo(ExceptionHandler<? super T> exceptionHandler)

handleEventException

public void handleEventException(java.lang.Throwable ex,
                                 long sequence,
                                 T event)

Description copied from interface: ExceptionHandler

Strategy for handling uncaught exceptions when processing an event.

If the strategy wishes to terminate further processing by the BatchEventProcessor then it should throw a RuntimeException.

Specified by:

handleEventException in interface ExceptionHandler<T>

Parameters:

ex - the exception that propagated from the EventHandler.

sequence - of the event which cause the exception.

event - being processed when the exception occurred. This can be null.

handleOnStartException

public void handleOnStartException(java.lang.Throwable ex)

Description copied from interface: ExceptionHandler

Callback to notify of an exception during LifecycleAware.onStart()

Specified by:

handleOnStartException in interface ExceptionHandler<T>

Parameters:

ex - throw during the starting process.

handleOnShutdownException

public void handleOnShutdownException(java.lang.Throwable ex)

Description copied from interface: ExceptionHandler

Callback to notify of an exception during LifecycleAware.onShutdown()

Specified by:

handleOnShutdownException in interface ExceptionHandler<T>

Parameters:

ex - throw during the shutdown process.

getExceptionHandler

private ExceptionHandler<? super T> getExceptionHandler()