private static class AsyncLoggerConfigDisruptor.Log4jEventWrapperHandler extends java.lang.Object implements com.lmax.disruptor.SequenceReportingEventHandler<AsyncLoggerConfigDisruptor.Log4jEventWrapper>
Modifier and Type | Field and Description |
---|---|
private int |
counter |
private static int |
NOTIFY_PROGRESS_THRESHOLD |
private com.lmax.disruptor.Sequence |
sequenceCallback |
Modifier | Constructor and Description |
---|---|
private |
Log4jEventWrapperHandler() |
Modifier and Type | Method and Description |
---|---|
private void |
notifyIntermediateProgress(long sequence)
Notify the BatchEventProcessor that the sequence has progressed.
|
void |
onEvent(AsyncLoggerConfigDisruptor.Log4jEventWrapper event,
long sequence,
boolean endOfBatch) |
void |
setSequenceCallback(com.lmax.disruptor.Sequence sequenceCallback) |
private static final int NOTIFY_PROGRESS_THRESHOLD
private com.lmax.disruptor.Sequence sequenceCallback
private int counter
public void setSequenceCallback(com.lmax.disruptor.Sequence sequenceCallback)
setSequenceCallback
in interface com.lmax.disruptor.SequenceReportingEventHandler<AsyncLoggerConfigDisruptor.Log4jEventWrapper>
public void onEvent(AsyncLoggerConfigDisruptor.Log4jEventWrapper event, long sequence, boolean endOfBatch) throws java.lang.Exception
onEvent
in interface com.lmax.disruptor.EventHandler<AsyncLoggerConfigDisruptor.Log4jEventWrapper>
java.lang.Exception
private void notifyIntermediateProgress(long sequence)