org.graylog2.shared.buffers

Class JournallingMessageHandler

java.lang.Object

org.graylog2.shared.buffers.JournallingMessageHandler

All Implemented Interfaces:

com.lmax.disruptor.EventHandler<RawMessageEvent>

public class JournallingMessageHandler
extends Object
implements com.lmax.disruptor.EventHandler<RawMessageEvent>

Constructor Summary

Constructors

Constructor and Description
JournallingMessageHandler(com.codahale.metrics.MetricRegistry metrics, Journal journal, ProcessingStatusRecorder processingStatusRecorder, Semaphore journalFilled)

Method Summary

Modifier and Type	Method and Description
void	onEvent(RawMessageEvent event, long sequence, boolean endOfBatch)

Methods inherited from class java.lang.Object

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

Constructor Detail

JournallingMessageHandler

@Inject
public JournallingMessageHandler(com.codahale.metrics.MetricRegistry metrics,
                                         Journal journal,
                                         ProcessingStatusRecorder processingStatusRecorder,
                                         @Named(value="JournalSignal")
                                         Semaphore journalFilled)

Method Detail

onEvent

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

Specified by:

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

Throws:

Exception