Package io.serverlessworkflow.impl.persistence

Class AbstractPersistenceInstanceWriter

java.lang.Object

io.serverlessworkflow.impl.persistence.AbstractPersistenceInstanceWriter

All Implemented Interfaces:

PersistenceInstanceWriter, AutoCloseable

Direct Known Subclasses:

TransactedPersistenceInstanceWriter

public abstract class AbstractPersistenceInstanceWriter
extends Object
implements PersistenceInstanceWriter

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CLOUD_EVENT_IDS

Constructor Summary

Constructors

Constructor	Description
AbstractPersistenceInstanceWriter()

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	aborted(io.serverlessworkflow.impl.WorkflowContextData workflowContext)
void	close()
CompletableFuture<Void>	completed(io.serverlessworkflow.impl.WorkflowContextData workflowContext)
protected CompletableFuture<Void>	doCompleteInstance(Consumer<PersistenceInstanceOperations> operation, io.serverlessworkflow.impl.WorkflowContextData workflowContext)
protected CompletableFuture<Void>	doStartInstance(Consumer<PersistenceInstanceOperations> operation, io.serverlessworkflow.impl.WorkflowContextData workflowContext)
protected abstract CompletableFuture<Void>	doTransaction(Consumer<PersistenceInstanceOperations> operation, io.serverlessworkflow.impl.WorkflowContextData context)
CompletableFuture<Void>	failed(io.serverlessworkflow.impl.WorkflowContextData workflowContext, Throwable ex)
protected CompletableFuture<Void>	removeProcessInstance(io.serverlessworkflow.impl.WorkflowContextData workflowContext)
CompletableFuture<Void>	resumed(io.serverlessworkflow.impl.WorkflowContextData workflowContext)
CompletableFuture<Void>	started(io.serverlessworkflow.impl.WorkflowContextData workflowContext)
CompletableFuture<Void>	suspended(io.serverlessworkflow.impl.WorkflowContextData workflowContext)
CompletableFuture<Void>	taskCompleted(io.serverlessworkflow.impl.WorkflowContextData workflowContext, io.serverlessworkflow.impl.TaskContextData taskContext)
CompletableFuture<Void>	taskRetried(io.serverlessworkflow.impl.WorkflowContextData workflowContext, io.serverlessworkflow.impl.TaskContextData taskContext)
CompletableFuture<Void>	taskStarted(io.serverlessworkflow.impl.WorkflowContextData workflowContext, io.serverlessworkflow.impl.TaskContextData taskContext)

Methods inherited from class java.lang.Object

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

Field Details

CLOUD_EVENT_IDS

public static final String CLOUD_EVENT_IDS

See Also:

• Constant Field Values

Constructor Details

AbstractPersistenceInstanceWriter

public AbstractPersistenceInstanceWriter()

Method Details

started

public CompletableFuture<Void> started(io.serverlessworkflow.impl.WorkflowContextData workflowContext)

Specified by:

started in interface PersistenceInstanceWriter

completed

public CompletableFuture<Void> completed(io.serverlessworkflow.impl.WorkflowContextData workflowContext)

Specified by:

completed in interface PersistenceInstanceWriter

failed

public CompletableFuture<Void> failed(io.serverlessworkflow.impl.WorkflowContextData workflowContext,
 Throwable ex)

Specified by:

failed in interface PersistenceInstanceWriter

aborted

public CompletableFuture<Void> aborted(io.serverlessworkflow.impl.WorkflowContextData workflowContext)

Specified by:

aborted in interface PersistenceInstanceWriter

removeProcessInstance

protected CompletableFuture<Void> removeProcessInstance(io.serverlessworkflow.impl.WorkflowContextData workflowContext)

taskStarted

public CompletableFuture<Void> taskStarted(io.serverlessworkflow.impl.WorkflowContextData workflowContext,
 io.serverlessworkflow.impl.TaskContextData taskContext)

Specified by:

taskStarted in interface PersistenceInstanceWriter

taskRetried

public CompletableFuture<Void> taskRetried(io.serverlessworkflow.impl.WorkflowContextData workflowContext,
 io.serverlessworkflow.impl.TaskContextData taskContext)

Specified by:

taskRetried in interface PersistenceInstanceWriter

taskCompleted

public CompletableFuture<Void> taskCompleted(io.serverlessworkflow.impl.WorkflowContextData workflowContext,
 io.serverlessworkflow.impl.TaskContextData taskContext)

Specified by:

taskCompleted in interface PersistenceInstanceWriter

suspended

public CompletableFuture<Void> suspended(io.serverlessworkflow.impl.WorkflowContextData workflowContext)

Specified by:

suspended in interface PersistenceInstanceWriter

resumed

public CompletableFuture<Void> resumed(io.serverlessworkflow.impl.WorkflowContextData workflowContext)

Specified by:

resumed in interface PersistenceInstanceWriter

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

doTransaction

protected abstract CompletableFuture<Void> doTransaction(Consumer<PersistenceInstanceOperations> operation,
 io.serverlessworkflow.impl.WorkflowContextData context)

doCompleteInstance

protected CompletableFuture<Void> doCompleteInstance(Consumer<PersistenceInstanceOperations> operation,
 io.serverlessworkflow.impl.WorkflowContextData workflowContext)

doStartInstance

protected CompletableFuture<Void> doStartInstance(Consumer<PersistenceInstanceOperations> operation,
 io.serverlessworkflow.impl.WorkflowContextData workflowContext)