Package org.apache.logging.log4j.core.async

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 java.lang.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 the Executor passed to the Disruptor constructor.

Field Summary

Fields

Modifier and Type	Field	Description
private int	counter
private static int	NOTIFY_PROGRESS_THRESHOLD
private com.lmax.disruptor.Sequence	sequenceCallback
private long	threadId

Constructor Summary

Constructors

Constructor	Description
RingBufferLogEventHandler()

Method Summary

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.
private void	notifyCallback(long sequence)
void	onEvent(RingBufferLogEvent event, long sequence, boolean endOfBatch)
void	onShutdown()
void	onStart()
void	setSequenceCallback(com.lmax.disruptor.Sequence sequenceCallback)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

NOTIFY_PROGRESS_THRESHOLD

private static final int NOTIFY_PROGRESS_THRESHOLD

See Also:

Constant Field Values

sequenceCallback

private com.lmax.disruptor.Sequence sequenceCallback

counter

private int counter

threadId

private long threadId

Constructor Detail

RingBufferLogEventHandler

public RingBufferLogEventHandler()

Method Detail

setSequenceCallback

public void setSequenceCallback(com.lmax.disruptor.Sequence sequenceCallback)

Specified by:

setSequenceCallback in interface com.lmax.disruptor.SequenceReportingEventHandler<RingBufferLogEvent>

onEvent

public void onEvent(RingBufferLogEvent event,
                    long sequence,
                    boolean endOfBatch)
             throws java.lang.Exception

Specified by:

onEvent in interface com.lmax.disruptor.EventHandler<RingBufferLogEvent>

Throws:

java.lang.Exception

notifyCallback

private void notifyCallback(long sequence)

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 interface com.lmax.disruptor.LifecycleAware

onShutdown

public void onShutdown()

Specified by:

onShutdown in interface com.lmax.disruptor.LifecycleAware