Package io.axoniq.framework.workflow.runtime.test.utils

Class ManualWorkflowScheduler

java.lang.Object

io.axoniq.framework.workflow.runtime.test.utils.ManualWorkflowScheduler

All Implemented Interfaces:

WorkflowScheduler

public class ManualWorkflowScheduler
extends Object
implements WorkflowScheduler

Manual timeout scheduler driven by the fixture clock.

Since:

5.4.0

Author:

Simon Zambrovski

Nested Class Summary

Nested classes/interfaces inherited from interface io.axoniq.framework.workflow.runtime.execution.WorkflowScheduler

WorkflowScheduler.ScheduledTask

Constructor Summary

Constructors

Constructor	Description
ManualWorkflowScheduler()

Method Summary

Modifier and Type	Method	Description
void	runDueTasks(Instant now)	Run all tasks due up to the given instant.
WorkflowScheduler.ScheduledTask	schedule(Instant deadline)	Schedules a deadline notification when fixture time reaches the given deadline.

Methods inherited from class java.lang.Object

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

Constructor Details

ManualWorkflowScheduler

public ManualWorkflowScheduler()

Method Details

schedule

public WorkflowScheduler.ScheduledTask schedule(Instant deadline)

Schedules a deadline notification when fixture time reaches the given deadline.

Specified by:

schedule in interface WorkflowScheduler

Parameters:

deadline - deadline according to fixture-controlled time

Returns:

scheduled task handle

runDueTasks

public void runDueTasks(Instant now)

Run all tasks due up to the given instant.

Parameters:

now - current fixture time