Class RingBufferLogEventHandler
- java.lang.Object
-
- org.apache.logging.log4j.core.async.RingBufferLogEventHandler
-
- All Implemented Interfaces:
com.lmax.disruptor.EventHandler<RingBufferLogEvent>
,com.lmax.disruptor.LifecycleAware
,com.lmax.disruptor.SequenceReportingEventHandler<RingBufferLogEvent>
public class RingBufferLogEventHandler extends Object implements com.lmax.disruptor.SequenceReportingEventHandler<RingBufferLogEvent>, com.lmax.disruptor.LifecycleAware
This event handler gets passed messages from the RingBuffer as they become available. Processing of these messages is done in a separate thread, controlled by theExecutor
passed to theDisruptor
constructor.
-
-
Constructor Summary
Constructors Constructor Description RingBufferLogEventHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
getThreadId()
Returns the thread ID of the background consumer thread, or-1
if the background thread has not started yet.void
onEvent(RingBufferLogEvent event, long sequence, boolean endOfBatch)
void
onShutdown()
void
onStart()
void
setSequenceCallback(com.lmax.disruptor.Sequence sequenceCallback)
-
-
-
Method Detail
-
setSequenceCallback
public void setSequenceCallback(com.lmax.disruptor.Sequence sequenceCallback)
- Specified by:
setSequenceCallback
in interfacecom.lmax.disruptor.SequenceReportingEventHandler<RingBufferLogEvent>
-
onEvent
public void onEvent(RingBufferLogEvent event, long sequence, boolean endOfBatch) throws Exception
- Specified by:
onEvent
in interfacecom.lmax.disruptor.EventHandler<RingBufferLogEvent>
- Throws:
Exception
-
getThreadId
public long getThreadId()
Returns the thread ID of the background consumer thread, or-1
if the background thread has not started yet.- Returns:
- the thread ID of the background consumer thread, or
-1
-
onStart
public void onStart()
- Specified by:
onStart
in interfacecom.lmax.disruptor.LifecycleAware
-
onShutdown
public void onShutdown()
- Specified by:
onShutdown
in interfacecom.lmax.disruptor.LifecycleAware
-
-