Package org.graylog2.shared.buffers.processors

Class ProcessBufferProcessor

java.lang.Object

org.graylog2.shared.buffers.processors.ProcessBufferProcessor

All Implemented Interfaces:

WorkHandler<MessageEvent>

public class ProcessBufferProcessor
extends Object
implements WorkHandler<MessageEvent>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ProcessBufferProcessor.Factory

Constructor Summary

Constructors

Constructor

Description

ProcessBufferProcessor(com.codahale.metrics.MetricRegistry metricRegistry, OrderedMessageProcessors orderedMessageProcessors, OutputBuffer outputBuffer, ProcessingStatusRecorder processingStatusRecorder, MessageULIDGenerator messageULIDGenerator, DecodingProcessor decodingProcessor, jakarta.inject.Provider<Stream> defaultStreamProvider, FailureSubmissionService failureSubmissionService, StreamMetrics streamMetrics, ClusterConfigService clusterConfigService, com.google.common.eventbus.EventBus eventBus)

Method Summary

Modifier and Type	Method	Description
Optional<Message>	getCurrentMessage()
Duration	getTimeStampGracePeriod()
void	handleGracePeriodUpdated(ClusterConfigChangedEvent event)
void	onEvent(MessageEvent event)
void	onShutdown()	Called once just before the thread is shutdown.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.graylog2.shared.buffers.WorkHandler

onStart

Constructor Details

ProcessBufferProcessor

public ProcessBufferProcessor(com.codahale.metrics.MetricRegistry metricRegistry,
 OrderedMessageProcessors orderedMessageProcessors,
 OutputBuffer outputBuffer,
 ProcessingStatusRecorder processingStatusRecorder,
 MessageULIDGenerator messageULIDGenerator,
 DecodingProcessor decodingProcessor,
 jakarta.inject.Provider<Stream> defaultStreamProvider,
 FailureSubmissionService failureSubmissionService,
 StreamMetrics streamMetrics,
 ClusterConfigService clusterConfigService,
 com.google.common.eventbus.EventBus eventBus)

Method Details

onEvent

public void onEvent(MessageEvent event)
             throws Exception

Specified by:

onEvent in interface WorkHandler<MessageEvent>

Throws:

Exception

getCurrentMessage

public Optional<Message> getCurrentMessage()

getTimeStampGracePeriod

public Duration getTimeStampGracePeriod()

handleGracePeriodUpdated

public void handleGracePeriodUpdated(ClusterConfigChangedEvent event)

onShutdown

public void onShutdown()

Description copied from interface: WorkHandler

Called once just before the thread is shutdown.

Sequence event processing will already have stopped before this method is called. No events will be processed after this message.

Specified by:

onShutdown in interface WorkHandler<MessageEvent>