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
Executor
passed to the Disruptor
constructor.Constructor | Description |
---|---|
RingBufferLogEventHandler() |
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) |
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-2018. 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.