4.5
Getting Started
Axon Framework
Deadline Managers
Deadlines can be scheduled from sagas and aggregates. The
DeadlineManager component is responsible for scheduling deadlines and invoking @DeadlineHandlerwhen the deadline is met. The DeadlineManager can be injected as a resource. It has two flavors: SimpleDeadlineManager and QuartzDeadlineManagerScheduling a Deadline
A deadline can be scheduled by providing a
Duration after which it will be triggered (or an Instant at which it will be triggered) and a deadline name.Scheduled Events or Scheduled DeadlinesUnlike Event Scheduling, when a deadline is triggered there will be no storing of the published message. Scheduling/Triggering a deadline does not involve anEventBus(orEventStore), hence the message is not stored.
1
class DeadlineSchedulingComponent {
2
void scheduleMyDeadline() {
3
String deadlineId =
4
deadlineManager.schedule(Duration.ofMillis(500), "myDeadline");
5
// For example store the `deadlineId`
6
}
7
}
Copied!
As a result we receive a
deadlineId which can be used to cancel the deadline. In most cases, storing this deadlineId as a field within your Aggregate/Saga is the most convenient. Cancelling a deadline could come in handy when a certain event means that the previously scheduled deadline has become obsolete (e.g. there is a deadline for paying the invoice, but the client payed the amount which means that the deadline is obsolete and can be canceled).1
class DeadlineCancelingComponent {
2
void cancelMyDeadline(String deadlineId) {
3
deadlineManager.cancelSchedule("myDeadline", deadlineId);
4
}
5
}
Copied!
Note that there are more options to cancel a deadline next to the previously mentioned:
cancelAll(String deadlineName)Cancels every scheduled deadline matching the givendeadlineName.Note that this thus also cancels deadlines from other aggregate and/or saga instances matching the name.cancelAllWithinScope(String deadlineName)Cancels a scheduled deadline matching the givendeadlineName, within theScopethe method is invoked in.For example, if this operation is performed from within "aggregate instance X",theScopeDescriptorfrom "aggregate instance X" will be used to cancel.cancelAllWithinScope(String deadlineName, ScopeDescriptor scope)Cancels a scheduled deadline matching the givendeadlineNameandScopeDescriptor.This allows canceling a deadline by name from differing scopes then the one it's executed in.
If you need contextual data about the deadline when the deadline is being handled, you can attach a deadline payload when scheduling a deadline:
1
class DeadlineSchedulingWithPayloadComponent {
2
void scheduleMyDeadlineWithPayload() {
3
String deadlineId = deadlineManager.schedule(
4
Duration.ofMillis(500), "myDeadline",
5
new MyDeadlinePayload(/* some user specific parameters */)
6
);
7
// For example store the `deadlineId`
8
}
9
}
Copied!
Handling a Deadline
We have now seen how to schedule a deadline. When the scheduled time is met, the corresponding
@DeadlineHandler is invoked. A @DeadlineHandler is a message handler like any other in Axon - it is possible to inject parameters for which ParameterResolvers exist.The Scope of a DeadlineWhen scheduling a deadline, the context from where it was scheduled is taken into account. This means a scheduled deadline will only be triggered in its originating context. Thus any@DeadlineHandlerannotated function you wish to be called on a met deadline, must be in the same Aggregate/Saga from which is was scheduled.Axon calls this context aScope. If necessary, implementing and providing your ownScopewill allow you to schedule deadlines in your custom, 'scoped' components.A Saga can end its lifecycle when@EndSagais added on a deadline handler.
A
@DeadlineHandler is matched based on the deadline name and the deadline payload.1
@DeadlineHandler(deadlineName = "myDeadline")
2
public void on(MyDeadlinePayload deadlinePayload) {
3
// handle the deadline
4
}
Copied!
If the deadline's name is not defined in the
@DeadlineHandler, matching will proceed based on the deadline payload alone.1
@DeadlineHandler
2
public void on(MyDeadlinePayload deadlinePayload) {
3
// handle the deadline
4
}
Copied!
If we scheduled a deadline without a specific payload, the
@DeadlineHandler does not have to specify the payload.1
@DeadlineHandler(deadlineName = "payloadlessDeadline")
2
public void on() {
3
// handle the deadline
4
}
Copied!
Using Time In Your Application
In cases where applications need to access the clock, they can take advantage of the clock used in the EventMessage, by accessing
GenericEventMessage.clock. This clock is set to Clock.systemUTC at runtime, and manipulated to simulate time during testing.1
public void handle(PublishTime cmd) {
2
apply(new TimePublishedEvent(GenericEventMessage.clock.instant()));
3
}
Copied!
Note that the current timestamp is automatically added to the EventMessage. If handlers only need to rely on the timestamp the event was published, they can access that timestamp directly, as described in Handling Events.
Last modified 9mo ago