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.SequenceReportingEventHandler<RingBufferLogEvent>

public class RingBufferLogEventHandler
extends Object
implements com.lmax.disruptor.SequenceReportingEventHandler<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.

Constructor Summary

Constructors

Constructor and Description
RingBufferLogEventHandler()

Method Summary

Modifier and Type	Method and Description
void	onEvent(RingBufferLogEvent event, long sequence, boolean endOfBatch)
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

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 Exception

Specified by:

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

Throws:

Exception