org.graylog2.shared.buffers.processors

Class ProcessBufferProcessor

java.lang.Object

org.graylog2.shared.buffers.processors.ProcessBufferProcessor

All Implemented Interfaces:

com.lmax.disruptor.WorkHandler<MessageEvent>

public class ProcessBufferProcessor
extends Object
implements com.lmax.disruptor.WorkHandler<MessageEvent>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ProcessBufferProcessor.Factory

Field Summary

Fields

Modifier and Type	Field and Description
protected com.codahale.metrics.MetricRegistry	metricRegistry

Constructor Summary

Constructors

Constructor and Description
ProcessBufferProcessor(com.codahale.metrics.MetricRegistry metricRegistry, OrderedMessageProcessors orderedMessageProcessors, OutputBuffer outputBuffer, DecodingProcessor decodingProcessor, com.google.inject.Provider<Stream> defaultStreamProvider)

Method Summary

Modifier and Type	Method and Description
void	onEvent(MessageEvent event)

Methods inherited from class java.lang.Object

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

Field Detail

metricRegistry

protected final com.codahale.metrics.MetricRegistry metricRegistry

Constructor Detail

ProcessBufferProcessor

public ProcessBufferProcessor(com.codahale.metrics.MetricRegistry metricRegistry,
                              OrderedMessageProcessors orderedMessageProcessors,
                              OutputBuffer outputBuffer,
                              DecodingProcessor decodingProcessor,
                              com.google.inject.Provider<Stream> defaultStreamProvider)

Method Detail

onEvent

public void onEvent(MessageEvent event)
             throws Exception

Specified by:

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

Throws:

Exception