org.axonframework.modelling.saga

Class AbstractSagaManager.Builder<T>

java.lang.Object

org.axonframework.modelling.saga.AbstractSagaManager.Builder<T>

Type Parameters:

T - a generic specifying the Saga type managed by this implementation

Direct Known Subclasses:

AnnotatedSagaManager.Builder

Enclosing class:

AbstractSagaManager<T>

public abstract static class AbstractSagaManager.Builder<T>
extends Object

Abstract Builder class to instantiate AbstractSagaManager implementations.

The sagaFactory is defaulted to a sagaType.newInstance() call throwing a SagaInstantiationException if it fails, the ListenerInvocationErrorHandler is defaulted to a LoggingErrorHandler and the SpanFactory defaults to a NoOpSpanFactory. The SagaRepository and sagaType are hard requirements and as such should be provided.

Field Summary

Fields

Modifier and Type	Field and Description
protected Class<T>	sagaType

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
AbstractSagaManager.Builder<T>	listenerInvocationErrorHandler(ListenerInvocationErrorHandler listenerInvocationErrorHandler) Sets the ListenerInvocationErrorHandler invoked when an error occurs.
AbstractSagaManager.Builder<T>	sagaFactory(Supplier<T> sagaFactory) Sets the sagaFactory of type Supplier responsible for creating new Saga instances.
AbstractSagaManager.Builder<T>	sagaRepository(SagaRepository<T> sagaRepository) Sets the SagaRepository of generic type T used to save and load Saga instances.
AbstractSagaManager.Builder<T>	sagaType(Class<T> sagaType) Sets the sagaType as a Class managed by this instance.
AbstractSagaManager.Builder<T>	spanFactory(SpanFactory spanFactory) Sets the SpanFactory implementation to use for providing tracing capabilities.
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

sagaType

protected Class<T> sagaType

Constructor Detail

Builder

public Builder()

Method Detail

sagaRepository

public AbstractSagaManager.Builder<T> sagaRepository(SagaRepository<T> sagaRepository)

Sets the SagaRepository of generic type T used to save and load Saga instances.

Parameters:

sagaRepository - a SagaRepository of generic type T used to save and load Saga instances

Returns:

the current Builder instance, for fluent interfacing

sagaType

public AbstractSagaManager.Builder<T> sagaType(Class<T> sagaType)

Sets the sagaType as a Class managed by this instance.

Parameters:

sagaType - the Class specifying the type of Saga managed by this instance

Returns:

the current Builder instance, for fluent interfacing

sagaFactory

public AbstractSagaManager.Builder<T> sagaFactory(Supplier<T> sagaFactory)

Sets the sagaFactory of type Supplier responsible for creating new Saga instances. Defaults to a sagaType.newInstance() call throwing a SagaInstantiationException if it fails.

Parameters:

sagaFactory - a Supplier of Saga type T responsible for creating new Saga instances

Returns:

the current Builder instance, for fluent interfacing

listenerInvocationErrorHandler

public AbstractSagaManager.Builder<T> listenerInvocationErrorHandler(ListenerInvocationErrorHandler listenerInvocationErrorHandler)

Sets the ListenerInvocationErrorHandler invoked when an error occurs. Defaults to a LoggingErrorHandler.

Parameters:

listenerInvocationErrorHandler - a ListenerInvocationErrorHandler invoked when an error occurs

Returns:

the current Builder instance, for fluent interfacing

spanFactory

public AbstractSagaManager.Builder<T> spanFactory(SpanFactory spanFactory)

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.

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