Package org.graylog2.shared.buffers.processors

Class DecodingProcessor

java.lang.Object

org.graylog2.shared.buffers.processors.DecodingProcessor

All Implemented Interfaces:

com.lmax.disruptor.EventHandler<MessageEvent>, com.lmax.disruptor.EventHandlerIdentity

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	DecodingProcessor.Factory

Constructor Summary

Constructors

Constructor	Description
DecodingProcessor(Map<String,Codec.Factory<? extends Codec>> codecFactory, ServerStatus serverStatus, com.codahale.metrics.MetricRegistry metricRegistry, Journal journal, MessageQueueAcknowledger acknowledger, com.codahale.metrics.Timer decodeTime, com.codahale.metrics.Timer parseTime)

Method Summary

Modifier and Type	Method	Description
default void	onBatchStart(long arg0, long arg1)
void	onEvent(MessageEvent event, long sequence, boolean endOfBatch)
default void	onShutdown()
default void	onStart()
default void	onTimeout(long arg0)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.lmax.disruptor.EventHandler

setSequenceCallback

Constructor Details

DecodingProcessor

public DecodingProcessor(Map<String,Codec.Factory<? extends Codec>> codecFactory,
 ServerStatus serverStatus,
 com.codahale.metrics.MetricRegistry metricRegistry,
 Journal journal,
 MessageQueueAcknowledger acknowledger,
 com.codahale.metrics.Timer decodeTime,
 com.codahale.metrics.Timer parseTime)

Method Details

onEvent

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

Specified by:

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

Throws:

Exception

onBatchStart

default void onBatchStart(long arg0,
 long arg1)

onStart

default void onStart()

onShutdown

default void onShutdown()

onTimeout

default void onTimeout(long arg0)
                throws Exception

Throws:

Exception