Package io.axoniq.framework.workflow.runtime.execution

Class EventSourcedWorkflowStore

java.lang.Object

io.axoniq.framework.workflow.runtime.execution.EventSourcedWorkflowStore

All Implemented Interfaces:

WorkflowStore

@Internal
public class EventSourcedWorkflowStore
extends Object
implements WorkflowStore

Event-sourcing repository-backed workflow store.

Loads the projection of workflow instances that have started without reaching a terminal state and the durable event-sourced state for an individual workflow instance.

Since:

5.4.0

Author:

Simon Zambrovski

Constructor Summary

Constructors

Constructor	Description
EventSourcedWorkflowStore(Repository<String,EventSourcedRunningWorkflows> runningWorkflowsRepository, Repository<String,EventSourcedWorkflowState> workflowStateRepository)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Optional<WorkflowState>>	findWorkflow(String workflowId, ProcessingContext processingContext)	Sources the state of a workflow that may not exist.
CompletableFuture<RunningWorkflows>	loadRunningWorkflows(ProcessingContext processingContext)	Loads the singleton running-workflows projection.
CompletableFuture<WorkflowState>	loadWorkflow(String workflowId, ProcessingContext processingContext)	Loads the event-sourced durable state for a workflow id.

Methods inherited from class java.lang.Object

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

Constructor Details

EventSourcedWorkflowStore

public EventSourcedWorkflowStore(Repository<String,EventSourcedRunningWorkflows> runningWorkflowsRepository,
 Repository<String,EventSourcedWorkflowState> workflowStateRepository)

Method Details

loadRunningWorkflows

public CompletableFuture<RunningWorkflows> loadRunningWorkflows(ProcessingContext processingContext)

Description copied from interface: WorkflowStore

Loads the singleton running-workflows projection.

Specified by:

loadRunningWorkflows in interface WorkflowStore

Parameters:

processingContext - processing context used for sourcing

Returns:

current running workflow ids

loadWorkflow

public CompletableFuture<WorkflowState> loadWorkflow(String workflowId,
 ProcessingContext processingContext)

Description copied from interface: WorkflowStore

Loads the event-sourced durable state for a workflow id.

Specified by:

loadWorkflow in interface WorkflowStore

Parameters:

workflowId - workflow identifier

processingContext - processing context used for sourcing

Returns:

durable workflow state

findWorkflow

public CompletableFuture<Optional<WorkflowState>> findWorkflow(String workflowId,
 ProcessingContext processingContext)

Description copied from interface: WorkflowStore

Sources the state of a workflow that may not exist.

Specified by:

findWorkflow in interface WorkflowStore

Parameters:

workflowId - identifier of the workflow to source

processingContext - processing context the sourcing runs in

Returns:

a future completing with the sourced state, or empty when the store holds no events for the workflow