Package org.axonframework.eventhandling

Class AbstractEventProcessor.Builder

java.lang.Object

org.axonframework.eventhandling.AbstractEventProcessor.Builder

Direct Known Subclasses:

PooledStreamingEventProcessor.Builder, SubscribingEventProcessor.Builder, TrackingEventProcessor.Builder

Enclosing class:

AbstractEventProcessor

public abstract static class AbstractEventProcessor.Builder
extends Object

Abstract Builder class to instantiate a AbstractEventProcessor.

The ErrorHandler is defaulted to a PropagatingErrorHandler, the MessageMonitor defaults to a NoOpMessageMonitor and the EventProcessorSpanFactory defaults to DefaultEventProcessorSpanFactory backed by a NoOpSpanFactory. The Event Processor name, EventHandlerInvoker and RollbackConfiguration are hard requirements and as such should be provided.

Field Summary

Fields

Modifier and Type	Field	Description
protected String	name

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
AbstractEventProcessor.Builder	errorHandler(ErrorHandler errorHandler)	Sets the ErrorHandler invoked when an UnitOfWork is rolled back during processing.
AbstractEventProcessor.Builder	eventHandlerInvoker(EventHandlerInvoker eventHandlerInvoker)	Sets the EventHandlerInvoker which will handle all the individual EventMessages.
AbstractEventProcessor.Builder	messageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)	Sets the MessageMonitor to monitor EventMessages before and after they're processed.
AbstractEventProcessor.Builder	name(String name)	Sets the name of this EventProcessor implementation.
AbstractEventProcessor.Builder	rollbackConfiguration(RollbackConfiguration rollbackConfiguration)	Sets the RollbackConfiguration specifying the rollback behavior of the UnitOfWork while processing a batch of events.
AbstractEventProcessor.Builder	spanFactory(EventProcessorSpanFactory spanFactory)	Sets the EventProcessorSpanFactory implementation to use for providing tracing capabilities.
AbstractEventProcessor.Builder	spanFactory(SpanFactory spanFactory)	Deprecated. Use invalid input: 'for more configuration options instead'
protected void	validate()	Validates whether the fields contained in this Builder are set accordingly.

Methods inherited from class java.lang.Object

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

Field Details

name

protected String name

Constructor Details

Builder

public Builder()

Method Details

name

public AbstractEventProcessor.Builder name(@Nonnull
 String name)

Sets the name of this EventProcessor implementation.

Parameters:

name - a String defining this EventProcessor implementation

Returns:

the current Builder instance, for fluent interfacing

eventHandlerInvoker

public AbstractEventProcessor.Builder eventHandlerInvoker(@Nonnull
 EventHandlerInvoker eventHandlerInvoker)

Sets the EventHandlerInvoker which will handle all the individual EventMessages.

Parameters:

eventHandlerInvoker - the EventHandlerInvoker which will handle all the individual EventMessages

Returns:

the current Builder instance, for fluent interfacing

rollbackConfiguration

public AbstractEventProcessor.Builder rollbackConfiguration(@Nonnull
 RollbackConfiguration rollbackConfiguration)

Sets the RollbackConfiguration specifying the rollback behavior of the UnitOfWork while processing a batch of events.

Parameters:

rollbackConfiguration - the RollbackConfiguration specifying the rollback behavior of the UnitOfWork while processing a batch of events.

Returns:

the current Builder instance, for fluent interfacing

errorHandler

public AbstractEventProcessor.Builder errorHandler(@Nonnull
 ErrorHandler errorHandler)

Sets the ErrorHandler invoked when an UnitOfWork is rolled back during processing. Defaults to a PropagatingErrorHandler.

Parameters:

errorHandler - the ErrorHandler invoked when an UnitOfWork is rolled back during processing

Returns:

the current Builder instance, for fluent interfacing

messageMonitor

public AbstractEventProcessor.Builder messageMonitor(@Nonnull
 MessageMonitor<? super EventMessage<?>> messageMonitor)

Sets the MessageMonitor to monitor EventMessages before and after they're processed. Defaults to a NoOpMessageMonitor.

Parameters:

messageMonitor - a MessageMonitor to monitor EventMessages before and after they're processed

Returns:

the current Builder instance, for fluent interfacing

spanFactory

@Deprecated
public AbstractEventProcessor.Builder spanFactory(@Nonnull
 SpanFactory spanFactory)

Deprecated.

Use invalid input: 'for more configuration options instead'

Sets the SpanFactory implementation to use for providing tracing capabilities. Defaults to a NoOpSpanFactory by default, which provides no tracing capabilities.

Parameters:

spanFactory - The SpanFactory implementation

Returns:

The current Builder instance, for fluent interfacing.

spanFactory

public AbstractEventProcessor.Builder spanFactory(@Nonnull
 EventProcessorSpanFactory spanFactory)

Sets the EventProcessorSpanFactory implementation to use for providing tracing capabilities. Defaults to a DefaultEventProcessorSpanFactory backed by a NoOpSpanFactory by default, which provides no tracing capabilities.

Parameters:

spanFactory - The SpanFactory implementation

Returns:

The current Builder instance, for fluent interfacing.

validate

protected void validate()
                 throws AxonConfigurationException

Validates whether the fields contained in this Builder are set accordingly.

Throws:

AxonConfigurationException - if one field is asserted to be incorrect according to the Builder's specifications