org.graylog2.buffers.processors

Class OutputBufferProcessor

java.lang.Object

org.graylog2.buffers.processors.OutputBufferProcessor

All Implemented Interfaces:

com.lmax.disruptor.EventHandler<MessageEvent>

public class OutputBufferProcessor
extends Object
implements com.lmax.disruptor.EventHandler<MessageEvent>

Author:

Lennart Koopmann

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	OutputBufferProcessor.Factory

Constructor Summary

Constructors

Constructor and Description
OutputBufferProcessor(Configuration configuration, com.codahale.metrics.MetricRegistry metricRegistry, OutputRegistry outputRegistry, ThroughputStats throughputStats, ServerStatus serverStatus, OutputBufferWatermark outputBufferWatermark, CachedOutputRouter outputRouter, long ordinal, long numberOfConsumers)

Method Summary

Methods

Modifier and Type	Method and Description
void	onEvent(MessageEvent 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

OutputBufferProcessor

public OutputBufferProcessor(Configuration configuration,
                     com.codahale.metrics.MetricRegistry metricRegistry,
                     OutputRegistry outputRegistry,
                     ThroughputStats throughputStats,
                     ServerStatus serverStatus,
                     OutputBufferWatermark outputBufferWatermark,
                     CachedOutputRouter outputRouter,
                     long ordinal,
                     long numberOfConsumers)

Method Detail

onEvent

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

Specified by:

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

Throws:

Exception