Package com.lmax.disruptor

Class BatchEventProcessorBuilder

java.lang.Object

com.lmax.disruptor.BatchEventProcessorBuilder

public final class BatchEventProcessorBuilder
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private int	maxBatchSize

Constructor Summary

Constructors

Constructor	Description
BatchEventProcessorBuilder()

Method Summary

Modifier and Type	Method	Description
<T> BatchEventProcessor<T>	build(DataProvider<T> dataProvider, SequenceBarrier sequenceBarrier, EventHandler<? super T> eventHandler)	Construct a EventProcessor that will automatically track the progress by updating its sequence when the EventHandler.onEvent(Object, long, boolean) method returns.
<T> BatchEventProcessor<T>	build(DataProvider<T> dataProvider, SequenceBarrier sequenceBarrier, RewindableEventHandler<? super T> rewindableEventHandler, BatchRewindStrategy batchRewindStrategy)	Construct a EventProcessor that will automatically track the progress by updating its sequence when the EventHandler.onEvent(Object, long, boolean) method returns.
BatchEventProcessorBuilder	setMaxBatchSize(int maxBatchSize)	Set the maximum number of events that will be processed in a batch before updating the sequence.

Methods inherited from class java.lang.Object

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

Field Details

maxBatchSize

private int maxBatchSize

Constructor Details

BatchEventProcessorBuilder

public BatchEventProcessorBuilder()

Method Details

setMaxBatchSize

public BatchEventProcessorBuilder setMaxBatchSize(int maxBatchSize)

Set the maximum number of events that will be processed in a batch before updating the sequence.

Parameters:

maxBatchSize - max number of events to process in one batch.

Returns:

The builder

build

public <T> BatchEventProcessor<T> build(DataProvider<T> dataProvider,
 SequenceBarrier sequenceBarrier,
 EventHandler<? super T> eventHandler)

Construct a EventProcessor that will automatically track the progress by updating its sequence when the EventHandler.onEvent(Object, long, boolean) method returns.

The created BatchEventProcessor will not support batch rewind, but EventHandler.setSequenceCallback(Sequence) will be supported.

Type Parameters:

T - event implementation storing the data for sharing during exchange or parallel coordination of an event.

Parameters:

dataProvider - to which events are published.

sequenceBarrier - on which it is waiting.

eventHandler - is the delegate to which events are dispatched.

Returns:

the BatchEventProcessor

build

public <T> BatchEventProcessor<T> build(DataProvider<T> dataProvider,
 SequenceBarrier sequenceBarrier,
 RewindableEventHandler<? super T> rewindableEventHandler,
 BatchRewindStrategy batchRewindStrategy)

Construct a EventProcessor that will automatically track the progress by updating its sequence when the EventHandler.onEvent(Object, long, boolean) method returns.

Type Parameters:

T - event implementation storing the data for sharing during exchange or parallel coordination of an event.

Parameters:

dataProvider - to which events are published.

sequenceBarrier - on which it is waiting.

rewindableEventHandler - is the delegate to which events are dispatched.

batchRewindStrategy - a BatchRewindStrategy for customizing how to handle a RewindableException.

Returns:

the BatchEventProcessor