Skip to content

Commit 50e81f0

Browse files
authored
Allow static use of scheduled service (#1159)
Signed-off-by: fjtirado <ftirados@redhat.com>
1 parent 8c69271 commit 50e81f0

File tree

1 file changed

+12
-2
lines changed

1 file changed

+12
-2
lines changed

impl/core/src/main/java/io/serverlessworkflow/impl/scheduler/ExecutorServiceWorkflowScheduler.java

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,14 +30,24 @@ public ExecutorServiceWorkflowScheduler(ScheduledExecutorService service) {
3030

3131
@Override
3232
public Cancellable scheduleEvery(WorkflowDefinition definition, Duration interval) {
33+
return scheduleEvery(service, definition, interval);
34+
}
35+
36+
@Override
37+
public Cancellable scheduleAfter(WorkflowDefinition definition, Duration delay) {
38+
return scheduleAfter(service, definition, delay);
39+
}
40+
41+
public static Cancellable scheduleEvery(
42+
ScheduledExecutorService service, WorkflowDefinition definition, Duration interval) {
3343
long delay = interval.toMillis();
3444
return new ScheduledServiceCancellable(
3545
service.scheduleAtFixedRate(
3646
new ScheduledInstanceRunnable(definition), delay, delay, TimeUnit.MILLISECONDS));
3747
}
3848

39-
@Override
40-
public Cancellable scheduleAfter(WorkflowDefinition definition, Duration delay) {
49+
public static Cancellable scheduleAfter(
50+
ScheduledExecutorService service, WorkflowDefinition definition, Duration delay) {
4151
return new ScheduledServiceCancellable(
4252
service.schedule(
4353
new ScheduledInstanceRunnable(definition), delay.toMillis(), TimeUnit.MILLISECONDS));

0 commit comments

Comments
 (0)