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 and Description
protected String	name

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and 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 {@link #spanFactory(EventProcessorSpanFactory) 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 Detail

name

protected String name

Constructor Detail

Builder

public Builder()

Method Detail

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 {@link #spanFactory(EventProcessorSpanFactory) 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