Package io.serverlessworkflow.impl.persistence

Class TransactedPersistenceInstanceWriter

java.lang.Object

io.serverlessworkflow.impl.persistence.AbstractPersistenceInstanceWriter

io.serverlessworkflow.impl.persistence.TransactedPersistenceInstanceWriter

All Implemented Interfaces:

PersistenceInstanceWriter, AutoCloseable

Direct Known Subclasses:

DefaultPersistenceInstanceWriter

public abstract class TransactedPersistenceInstanceWriter
extends AbstractPersistenceInstanceWriter

Field Summary

Fields inherited from class io.serverlessworkflow.impl.persistence.AbstractPersistenceInstanceWriter

CLOUD_EVENT_IDS

Constructor Summary

Constructors

Constructor	Description
TransactedPersistenceInstanceWriter()

Method Summary

Modifier and Type	Method	Description
void	close()
protected CompletableFuture<Void>	doCompleteInstance(Consumer<PersistenceInstanceOperations> operation, io.serverlessworkflow.impl.WorkflowContextData context)
protected CompletableFuture<Void>	doStartInstance(Consumer<PersistenceInstanceOperations> operation, io.serverlessworkflow.impl.WorkflowContextData context)
protected CompletableFuture<Void>	doTransaction(Consumer<PersistenceInstanceOperations> operation, io.serverlessworkflow.impl.WorkflowContextData context)
protected abstract void	doTransaction(Consumer<PersistenceInstanceOperations> operation, io.serverlessworkflow.impl.WorkflowDefinitionData definition)
protected abstract PersistenceExecutor	persistenceExecutor()

Methods inherited from class io.serverlessworkflow.impl.persistence.AbstractPersistenceInstanceWriter

aborted, completed, failed, removeProcessInstance, resumed, started, suspended, taskCompleted, taskRetried, taskStarted

Methods inherited from class java.lang.Object

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

Constructor Details

TransactedPersistenceInstanceWriter

public TransactedPersistenceInstanceWriter()

Method Details

doTransaction

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

Specified by:

doTransaction in class AbstractPersistenceInstanceWriter

doStartInstance

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

Overrides:

doStartInstance in class AbstractPersistenceInstanceWriter

doCompleteInstance

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

Overrides:

doCompleteInstance in class AbstractPersistenceInstanceWriter

doTransaction

protected abstract void doTransaction(Consumer<PersistenceInstanceOperations> operation,
 io.serverlessworkflow.impl.WorkflowDefinitionData definition)

close

public void close()

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractPersistenceInstanceWriter

persistenceExecutor

protected abstract PersistenceExecutor persistenceExecutor()