org.axonframework.deadline.quartz

Class QuartzDeadlineManager.Builder

java.lang.Object

org.axonframework.deadline.quartz.QuartzDeadlineManager.Builder

Enclosing class:

QuartzDeadlineManager

public static class QuartzDeadlineManager.Builder
extends Object

Builder class to instantiate a QuartzDeadlineManager.

The TransactionManager is defaulted to an NoTransactionManager, and the Serializer to a XStreamSerializer. The Scheduler and ScopeAwareProvider are hard requirements and as such should be provided.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
QuartzDeadlineManager	build() Initializes a QuartzDeadlineManager as specified through this Builder.
QuartzDeadlineManager.Builder	refireImmediatelyPolicy(Predicate<Throwable> refireImmediatelyPolicy) Sets a Predicate taking a Throwable to decided whether a failed DeadlineJob should be 'refired' immediately.
QuartzDeadlineManager.Builder	scheduler(org.quartz.Scheduler scheduler) Sets the Scheduler used for scheduling and triggering purposes of the deadlines.
QuartzDeadlineManager.Builder	scopeAwareProvider(ScopeAwareProvider scopeAwareProvider) Sets the ScopeAwareProvider which is capable of providing a stream of Scope instances for a given ScopeDescriptor.
QuartzDeadlineManager.Builder	serializer(Serializer serializer) Sets the Serializer used to de-/serialize the DeadlineMessage and the ScopeDescriptor into the JobDataMap.
QuartzDeadlineManager.Builder	transactionManager(TransactionManager transactionManager) Sets the TransactionManager used to build transactions and ties them to deadline.
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

Constructor Detail

Builder

public Builder()

Method Detail

scheduler

public QuartzDeadlineManager.Builder scheduler(org.quartz.Scheduler scheduler)

Sets the Scheduler used for scheduling and triggering purposes of the deadlines.

Parameters:

scheduler - a Scheduler used for scheduling and triggering purposes of the deadlines

Returns:

the current Builder instance, for fluent interfacing

scopeAwareProvider

public QuartzDeadlineManager.Builder scopeAwareProvider(ScopeAwareProvider scopeAwareProvider)

Sets the ScopeAwareProvider which is capable of providing a stream of Scope instances for a given ScopeDescriptor. Used to return the right Scope to trigger a deadline in.

Parameters:

scopeAwareProvider - a ScopeAwareProvider used to find the right Scope to trigger a deadline in

Returns:

the current Builder instance, for fluent interfacing

transactionManager

public QuartzDeadlineManager.Builder transactionManager(TransactionManager transactionManager)

Sets the TransactionManager used to build transactions and ties them to deadline. Defaults to a NoTransactionManager.

Parameters:

transactionManager - a TransactionManager used to build transactions and ties them to deadline

Returns:

the current Builder instance, for fluent interfacing

serializer

public QuartzDeadlineManager.Builder serializer(Serializer serializer)

Sets the Serializer used to de-/serialize the DeadlineMessage and the ScopeDescriptor into the JobDataMap. Defaults to a XStreamSerializer.

Parameters:

serializer - a Serializer used to de-/serialize the DeadlineMessage and the ScopeDescriptor into the JobDataMap

Returns:

the current Builder instance, for fluent interfacing

refireImmediatelyPolicy

public QuartzDeadlineManager.Builder refireImmediatelyPolicy(Predicate<Throwable> refireImmediatelyPolicy)

Sets a Predicate taking a Throwable to decided whether a failed DeadlineJob should be 'refired' immediately. Defaults to a Predicate which will refire immediately on non-AxonNonTransientExceptions.

Parameters:

refireImmediatelyPolicy - a Predicate taking a Throwable to decided whether a failed DeadlineJob should be 'refired' immediately

Returns:

the current Builder instance, for fluent interfacing

build

public QuartzDeadlineManager build()

Initializes a QuartzDeadlineManager as specified through this Builder.

Returns:

a QuartzDeadlineManager as specified through this Builder

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