org.axonframework.eventhandling

Class AbstractEventProcessor.Builder

java.lang.Object

org.axonframework.eventhandling.AbstractEventProcessor.Builder

Direct Known Subclasses:

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 and the MessageMonitor defaults to a NoOpMessageMonitor. 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.
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(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(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(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(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(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

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