Class RingBufferLogEventHandler4

java.lang.Object

org.apache.logging.log4j.core.async.RingBufferLogEventHandler4

All Implemented Interfaces:

com.lmax.disruptor.EventHandler<RingBufferLogEvent>

Direct Known Subclasses:

RingBufferLogEventHandler

class RingBufferLogEventHandler4
extends Object
implements com.lmax.disruptor.EventHandler<RingBufferLogEvent>

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. *

* Warning: this class only works with Disruptor 4.x. *

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
RingBufferLogEventHandler4()

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 Object

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

Field Details

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 Details

RingBufferLogEventHandler4

RingBufferLogEventHandler4()

Method Details

setSequenceCallback

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

onEvent

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

Specified by:

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

Throws:

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()

onShutdown

public void onShutdown()