Complete Running Timers

Workflows are able to wait for a specific time or duration. If we want to manually complete the waiting, we can do that through the completeTimers method of the client.

After having fixed the workflow definition, the instance can be resume by using:

// stub targeting a running HelloWorkflow workflow with a specific id
HelloWorkflow w =
    client.getWorkflowById(HelloWorkflow.class, "05694902-5aa4-469f-824c-7015b0df906c");

// complete current awaiting timers
client.completeTimers(w);

// stub targeting a running HelloWorkflow workflow with a specific id
val w : HelloWorkflow =
    client.getWorkflowById(HelloWorkflow::class.java, "05694902-5aa4-469f-824c-7015b0df906c")

// complete current awaiting timers
client.completeTimers(w)

We can also target workflows by tag:

// stub targeting a running HelloWorkflow workflow with a specific id
HelloWorkflow w =
    client.getWorkflowByTag(HelloWorkflow.class, "foo");

// complete current awaiting timers
client.completeTimers(w);

// stub targeting a running HelloWorkflow workflow with a specific id
val w : HelloWorkflow =
    client.getWorkflowByTag(HelloWorkflow::class.java, "foo")

// complete current awaiting timers
client.completeTimers(w)

The completeTimers method returns when the adhoc message is sent to Pulsar. We can use the completeTimersAsync method if we want to send the adhoc message asynchronously.

The completeTimers method completes only the timers currently waiting on the main method of the targeted workflow(s).

If we dispatched a parallel method, and want to complete timers on this method, we can do it with:

// stub targeting a running HelloWorkflow workflow with a specific id
HelloWorkflow w =
    client.getWorkflowById(HelloWorkflow.class, "05694902-5aa4-469f-824c-7015b0df906c");

// complete current awaiting timers on method running with this id
client.completeTimers(w, "a2ea0647-4e22-4086-9a97-d28c815713b7");

// stub targeting a running HelloWorkflow workflow with a specific id
val w : HelloWorkflow =
    client.getWorkflowById(HelloWorkflow::class.java, "05694902-5aa4-469f-824c-7015b0df906c")

// complete current awaiting timers on method running with this id
client.completeTimers(w, "a2ea0647-4e22-4086-9a97-d28c815713b7")