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, de.huxhorn.sulky.ulid.ULID ulid, MessageULIDGenerator messageULIDGenerator, DecodingProcessor decodingProcessor, jakarta.inject.Provider<Stream> defaultStreamProvider, FailureSubmissionService failureSubmissionService, StreamMetrics streamMetrics)

Method Summary

Modifier and Type	Method	Description
Optional<Message>	getCurrentMessage()
void	onEvent(MessageEvent event)

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

onShutdown, onStart

Constructor Details

ProcessBufferProcessor

public ProcessBufferProcessor(com.codahale.metrics.MetricRegistry metricRegistry,
 OrderedMessageProcessors orderedMessageProcessors,
 OutputBuffer outputBuffer,
 ProcessingStatusRecorder processingStatusRecorder,
 de.huxhorn.sulky.ulid.ULID ulid,
 MessageULIDGenerator messageULIDGenerator,
 DecodingProcessor decodingProcessor,
 jakarta.inject.Provider<Stream> defaultStreamProvider,
 FailureSubmissionService failureSubmissionService,
 StreamMetrics streamMetrics)

Method Details

onEvent

public void onEvent(MessageEvent event)
             throws Exception

Specified by:

onEvent in interface WorkHandler<MessageEvent>

Throws:

Exception

getCurrentMessage

public Optional<Message> getCurrentMessage()