Package | Description |
---|---|
com.lmax.disruptor |
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
|
com.lmax.disruptor.dsl |
Modifier and Type | Class and Description |
---|---|
class |
FatalExceptionHandler
Convenience implementation of an exception handler that using standard JDK logging to log
the exception as
Level .SEVERE and re-throw it wrapped in a RuntimeException |
class |
IgnoreExceptionHandler
Convenience implementation of an exception handler that using standard JDK logging to log
the exception as
Level .INFO |
Modifier and Type | Field and Description |
---|---|
private ExceptionHandler<? super T> |
WorkProcessor.exceptionHandler |
private ExceptionHandler<? super T> |
BatchEventProcessor.exceptionHandler |
Modifier and Type | Method and Description |
---|---|
void |
BatchEventProcessor.setExceptionHandler(ExceptionHandler<? super T> exceptionHandler)
Set a new
ExceptionHandler for handling exceptions propagated out of the BatchEventProcessor |
Constructor and Description |
---|
WorkerPool(EventFactory<T> eventFactory,
ExceptionHandler<? super T> exceptionHandler,
WorkHandler<? super T>... workHandlers)
Construct a work pool with an internal
RingBuffer for convenience. |
WorkerPool(RingBuffer<T> ringBuffer,
SequenceBarrier sequenceBarrier,
ExceptionHandler<? super T> exceptionHandler,
WorkHandler<? super T>... workHandlers)
Create a worker pool to enable an array of
WorkHandler s to consume published sequences. |
WorkProcessor(RingBuffer<T> ringBuffer,
SequenceBarrier sequenceBarrier,
WorkHandler<? super T> workHandler,
ExceptionHandler<? super T> exceptionHandler,
Sequence workSequence)
Construct a
WorkProcessor . |
Modifier and Type | Class and Description |
---|---|
class |
ExceptionHandlerWrapper<T> |
Modifier and Type | Field and Description |
---|---|
private ExceptionHandler<? super T> |
ExceptionHandlerWrapper.delegate |
private ExceptionHandler<? super T> |
Disruptor.exceptionHandler |
Modifier and Type | Method and Description |
---|---|
void |
Disruptor.handleExceptionsWith(ExceptionHandler<? super T> exceptionHandler)
Deprecated.
This method only applies to future event handlers. Use setDefaultExceptionHandler instead which applies to existing and new event handlers.
|
void |
Disruptor.setDefaultExceptionHandler(ExceptionHandler<? super T> exceptionHandler)
Specify an exception handler to be used for event handlers and worker pools created by this Disruptor.
|
void |
ExceptionHandlerWrapper.switchTo(ExceptionHandler<? super T> exceptionHandler) |
void |
ExceptionHandlerSetting.with(ExceptionHandler<? super T> exceptionHandler)
Specify the
ExceptionHandler to use with the event handler. |