org.axonframework.deadline.jobrunr

Class JobRunrDeadlineManager

java.lang.Object

org.axonframework.deadline.AbstractDeadlineManager

org.axonframework.deadline.jobrunr.JobRunrDeadlineManager

All Implemented Interfaces:

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

public class JobRunrDeadlineManager
extends AbstractDeadlineManager

Implementation of DeadlineManager that delegates scheduling and triggering to a Jobrunr JobScheduler.

Since:

4.7.0

Author:

Tom de Backer, Gerard Klijs

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JobRunrDeadlineManager(JobRunrDeadlineManager.Builder builder) Instantiate a JobRunrDeadlineManager based on the fields contained in the JobRunrDeadlineManager.Builder.

Method Summary

Modifier and Type	Method and Description
static JobRunrDeadlineManager.Builder	builder() Instantiate a Builder to be able to create a JobRunrDeadlineManager.
void	cancelAll(String deadlineName) Cancels all the deadlines corresponding to the given deadlineName.
void	cancelAllWithinScope(String deadlineName, ScopeDescriptor scope) Cancels all deadlines corresponding to the given deadlineName and scope.
void	cancelSchedule(String deadlineName, String scheduleId) Cancels the deadline corresponding to the given deadlineName / scheduleId combination.
void	execute(String serializedDeadlineDetails) This function should only be called via Jobrunr when a deadline was triggered.
String	schedule(Instant triggerDateTime, String deadlineName, Object messageOrPayload, ScopeDescriptor deadlineScope) Schedules a deadline at given triggerDateTime with provided context.
void	shutdown() Shuts down this deadline manager.

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

cancelAllWithinScope, schedule, schedule, schedule, schedule, schedule

Constructor Detail

JobRunrDeadlineManager

protected JobRunrDeadlineManager(JobRunrDeadlineManager.Builder builder)

Instantiate a JobRunrDeadlineManager based on the fields contained in the JobRunrDeadlineManager.Builder.

Will assert that the ScopeAwareProvider, JobScheduler and Serializer are not null, and will throw an AxonConfigurationException if any of them is null.

Parameters:

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

Method Detail

builder

public static JobRunrDeadlineManager.Builder builder()

Instantiate a Builder to be able to create a JobRunrDeadlineManager.

The TransactionManager is defaulted to a NoTransactionManager.

The SpanFactory is defaulted to a NoOpSpanFactory.

The JobScheduler, ScopeAwareProvider and Serializer are hard requirements and as such should be provided.

Returns:

a Builder to be able to create a JobRunrDeadlineManager

schedule

public String schedule(@Nonnull
                       Instant triggerDateTime,
                       @Nonnull
                       String deadlineName,
                       @Nullable
                       Object messageOrPayload,
                       @Nonnull
                       ScopeDescriptor deadlineScope)

Description copied from interface: DeadlineManager

Schedules a deadline at given triggerDateTime with provided context. The returned scheduleId and provided deadlineName 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.

Parameters:

triggerDateTime - A Instant denoting the moment to trigger the deadline handling

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:

the scheduleId as a String to use when cancelling the schedule

cancelSchedule

public void cancelSchedule(@Nonnull
                           String deadlineName,
                           @Nonnull
                           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(@Nonnull
                      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

cancelAllWithinScope

public void cancelAllWithinScope(@Nonnull
                                 String deadlineName,
                                 @Nonnull
                                 ScopeDescriptor scope)

Description copied from interface: DeadlineManager

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

Parameters:

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

scope - a ScopeDescriptor describing the scope within which the deadline was scheduled

execute

public void execute(@Nonnull
                    String serializedDeadlineDetails)

This function should only be called via Jobrunr when a deadline was triggered. It will try to execute the scheduled deadline on the set scope. It will throw a DeadlineException in case of errors such that they will be optionally retried by Jobrunr.

Parameters:

serializedDeadlineDetails - byte[] containing the serialized DeadlineDetails object with all the needed details to execute.

shutdown

public void shutdown()

Description copied from interface: DeadlineManager

Shuts down this deadline manager.