org.axonframework.deadline

Class SimpleDeadlineManager

java.lang.Object

org.axonframework.deadline.AbstractDeadlineManager

org.axonframework.deadline.SimpleDeadlineManager

All Implemented Interfaces:

DeadlineManager, MessageDispatchInterceptorSupport<DeadlineMessage<?>>, MessageHandlerInterceptorSupport<DeadlineMessage<?>>

public class SimpleDeadlineManager
extends AbstractDeadlineManager

Implementation of DeadlineManager which uses Java's ScheduledExecutorService as scheduling and triggering mechanism.

Note that this mechanism is non-persistent. Scheduled tasks will be lost then the JVM is shut down, unless special measures have been taken to prevent that. For more flexible and powerful scheduling options, see QuartzDeadlineManager.

Since:

3.3

Author:

Milan Savic, Steven van Beelen

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SimpleDeadlineManager.Builder Builder class to instantiate a SimpleDeadlineManager.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SimpleDeadlineManager(SimpleDeadlineManager.Builder builder) Instantiate a SimpleDeadlineManager based on the fields contained in the SimpleDeadlineManager.Builder to handle the process around scheduling and triggering a DeadlineMessage.

Method Summary

Modifier and Type	Method and Description
static SimpleDeadlineManager.Builder	builder() Instantiate a Builder to be able to create a SimpleDeadlineManager.
void	cancelAll(String deadlineName) Cancels all the deadlines corresponding to the given deadlineName.
void	cancelSchedule(String deadlineName, String scheduleId) Cancels the deadline corresponding to the given deadlineName / scheduleId combination.
String	schedule(Duration triggerDuration, String deadlineName, Object messageOrPayload, ScopeDescriptor deadlineScope) Schedules a deadline after the given triggerDuration with provided context.

Methods inherited from class org.axonframework.deadline.AbstractDeadlineManager

dispatchInterceptors, handlerInterceptors, processDispatchInterceptors, registerDispatchInterceptor, registerHandlerInterceptor, runOnPrepareCommitOrNow

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.deadline.DeadlineManager

schedule, schedule, schedule, schedule, schedule

Constructor Detail

SimpleDeadlineManager

protected SimpleDeadlineManager(SimpleDeadlineManager.Builder builder)

Instantiate a SimpleDeadlineManager based on the fields contained in the SimpleDeadlineManager.Builder to handle the process around scheduling and triggering a DeadlineMessage.

Will assert that the ScopeAwareProvider, ScheduledExecutorService and TransactionManager are not null, and will throw an AxonConfigurationException if either of them is null.

Parameters:

builder - the SimpleDeadlineManager.Builder used to instantiate a SimpleDeadlineManager instance

Method Detail

builder

public static SimpleDeadlineManager.Builder builder()

Instantiate a Builder to be able to create a SimpleDeadlineManager.

The ScheduledExecutorService is defaulted to an Executors.newSingleThreadScheduledExecutor() which contains an AxonThreadFactory, and the TransactionManager defaults to a NoTransactionManager. The ScopeAwareProvider is a hard requirement and as such should be provided.

Returns:

a Builder to be able to create a SimpleDeadlineManager

schedule

public String schedule(Duration triggerDuration,
                       String deadlineName,
                       Object messageOrPayload,
                       ScopeDescriptor deadlineScope)

Description copied from interface: DeadlineManager

Schedules a deadline after the given triggerDuration with provided context. The provided deadlineName / scheduleId combination can be used to cancel the scheduled deadline.

The given messageOrPayload may be any object, as well as a DeadlineMessage. In the latter case, the instance provided is the donor for the payload and MetaData of the actual deadline being used. In the former case, the given messageOrPayload will be wrapped as the payload of a DeadlineMessage.

Scheduling a deadline with the same deadlineName and scheduleId will replace the previous schedule with the new one.

Parameters:

triggerDuration - A Duration describing the waiting period before handling the deadline

deadlineName - A String representing the name of the deadline to schedule

messageOrPayload - A Message or payload for a message as an Object

deadlineScope - A ScopeDescriptor describing the scope within which the deadline was scheduled

Returns:

A schedule id to use when cancelling the schedule

cancelSchedule

public void cancelSchedule(String deadlineName,
                           String scheduleId)

Description copied from interface: DeadlineManager

Cancels the deadline corresponding to the given deadlineName / scheduleId combination. This method has no impact on deadlines which have already been triggered.

Parameters:

deadlineName - A String representing the name of the deadline to cancel

scheduleId - The String denoting the scheduled deadline to cancel

cancelAll

public void cancelAll(String deadlineName)

Description copied from interface: DeadlineManager

Cancels all the deadlines corresponding to the given deadlineName. This method has no impact on deadlines which have already been triggered.

Parameters:

deadlineName - A String representing the name of the deadlines to cancel