public class RingBufferLogEventHandler extends Object implements com.lmax.disruptor.SequenceReportingEventHandler<RingBufferLogEvent>, com.lmax.disruptor.LifecycleAware
Executor
passed to the Disruptor
constructor.Constructor and Description |
---|
RingBufferLogEventHandler() |
Modifier and Type | Method and 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) |
public void setSequenceCallback(com.lmax.disruptor.Sequence sequenceCallback)
setSequenceCallback
in interface com.lmax.disruptor.SequenceReportingEventHandler<RingBufferLogEvent>
public void onEvent(RingBufferLogEvent event, long sequence, boolean endOfBatch) throws Exception
onEvent
in interface com.lmax.disruptor.EventHandler<RingBufferLogEvent>
Exception
public long getThreadId()
-1
if the background thread has not started
yet.-1
public void onStart()
onStart
in interface com.lmax.disruptor.LifecycleAware
public void onShutdown()
onShutdown
in interface com.lmax.disruptor.LifecycleAware
Copyright © 1999-2017. All Rights Reserved.
Apache Logging, Apache Log4j, Log4j, Apache, the Apache feather logo, the Apache Logging project logo, and the Apache Log4j logo are trademarks of The Apache Software Foundation.