Package su.onno.process

Class JdbcProcessEngine

java.lang.Object

su.onno.process.JdbcProcessEngine

All Implemented Interfaces:

ProcessEngine

public final class JdbcProcessEngine
extends Object
implements ProcessEngine

Core JDBI runtime for durable, versioned typed process definitions.

Execution tokens, rather than onno_process_instances._current_step, are authoritative. The scalar current step is retained as a compatibility projection for sequential consumers.

Constructor Summary

Constructors

Constructor	Description
JdbcProcessEngine(org.jdbi.v3.core.Jdbi jdbi, ProcessDefinitions definitions, MetadataRegistry registry, ProcessPayloadCodec payloadCodec, ProcessEventPublisher events)

Method Summary

Modifier and Type	Method	Description
ProcessSnapshot	cancel(UUID instanceId, String reason, ProcessActor actor)	Cancel an active process and all of its live tasks, timers, branches, and subprocesses.
ProcessWorkItem	claim(UUID workItemId, ProcessActor actor)
ProcessSnapshot	complete(UUID workItemId, String outcomeName, ProcessActor actor)	Dynamic/transport boundary used when an enum constant arrives as JSON text.
ProcessWorkItem	delegate(UUID workItemId, ProcessIdentity target, String reason, ProcessActor actor)	Transfer a claimed task to another stable authenticated identity.
Optional<ProcessSnapshot>	find(UUID instanceId)
List<ProcessTransitionSnapshot>	history(UUID instanceId)
List<ProcessWorkItem>	inbox(ProcessActor actor)
List<ProcessSnapshot>	instances(ProcessActor actor)	Process instances visible to an actor through start, participation, or administration.
ProcessSnapshot	migrate(UUID instanceId, ProcessActor actor)	Apply the registered definition-migration chain to the latest definition version.
int	runPending(int limit)	Advance due timers and completed/cancelled subprocess waits.
<P, S extends Enum<S> & ProcessStepKey> ProcessSnapshot	start(ProcessDefinition<P,S> definition, P payload, ProcessActor actor)
List<ProcessTokenSnapshot>	tokens(UUID instanceId)	Active and historical execution tokens for an inspectable process timeline.
List<ProcessWorkItemEventSnapshot>	workItemHistory(UUID workItemId, ProcessActor actor)	Authorized, chronological audit history for one human task.

Methods inherited from class java.lang.Object

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

Methods inherited from interface su.onno.process.ProcessEngine

complete

Constructor Details

JdbcProcessEngine

public JdbcProcessEngine(org.jdbi.v3.core.Jdbi jdbi,
 ProcessDefinitions definitions,
 MetadataRegistry registry,
 ProcessPayloadCodec payloadCodec,
 ProcessEventPublisher events)

Method Details

start

public <P,
S extends Enum<S> & ProcessStepKey>
ProcessSnapshot start(ProcessDefinition<P,S> definition,
 P payload,
 ProcessActor actor)

Specified by:

start in interface ProcessEngine

find

public Optional<ProcessSnapshot> find(UUID instanceId)

Specified by:

find in interface ProcessEngine

instances

public List<ProcessSnapshot> instances(ProcessActor actor)

Description copied from interface: ProcessEngine

Process instances visible to an actor through start, participation, or administration.

Specified by:

instances in interface ProcessEngine

history

public List<ProcessTransitionSnapshot> history(UUID instanceId)

Specified by:

history in interface ProcessEngine

tokens

public List<ProcessTokenSnapshot> tokens(UUID instanceId)

Description copied from interface: ProcessEngine

Active and historical execution tokens for an inspectable process timeline.

Specified by:

tokens in interface ProcessEngine

inbox

public List<ProcessWorkItem> inbox(ProcessActor actor)

Specified by:

inbox in interface ProcessEngine

claim

public ProcessWorkItem claim(UUID workItemId,
 ProcessActor actor)

Specified by:

claim in interface ProcessEngine

delegate

public ProcessWorkItem delegate(UUID workItemId,
 ProcessIdentity target,
 String reason,
 ProcessActor actor)

Description copied from interface: ProcessEngine

Transfer a claimed task to another stable authenticated identity.

The current assignee (or an administrator) may delegate. The reason is required and the transfer is recorded in ProcessEngine.workItemHistory(java.util.UUID, su.onno.process.ProcessActor).

Specified by:

delegate in interface ProcessEngine

workItemHistory

public List<ProcessWorkItemEventSnapshot> workItemHistory(UUID workItemId,
 ProcessActor actor)

Description copied from interface: ProcessEngine

Authorized, chronological audit history for one human task.

Specified by:

workItemHistory in interface ProcessEngine

complete

public ProcessSnapshot complete(UUID workItemId,
 String outcomeName,
 ProcessActor actor)

Description copied from interface: ProcessEngine

Dynamic/transport boundary used when an enum constant arrives as JSON text.

Specified by:

complete in interface ProcessEngine

cancel

public ProcessSnapshot cancel(UUID instanceId,
 String reason,
 ProcessActor actor)

Description copied from interface: ProcessEngine

Cancel an active process and all of its live tasks, timers, branches, and subprocesses.

Specified by:

cancel in interface ProcessEngine

migrate

public ProcessSnapshot migrate(UUID instanceId,
 ProcessActor actor)

Description copied from interface: ProcessEngine

Apply the registered definition-migration chain to the latest definition version.

Specified by:

migrate in interface ProcessEngine

runPending

public int runPending(int limit)

Description copied from interface: ProcessEngine

Advance due timers and completed/cancelled subprocess waits.

The starter invokes this from its durable background-job scheduler. Calling it from application code is safe; row locks and token state make duplicate polls no-ops.

Specified by:

runPending in interface ProcessEngine