Package io.serverlessworkflow.impl.persistence

Class DefaultPersistenceInstanceWriter

java.lang.Object

io.serverlessworkflow.impl.persistence.AbstractPersistenceInstanceWriter

io.serverlessworkflow.impl.persistence.TransactedPersistenceInstanceWriter

io.serverlessworkflow.impl.persistence.DefaultPersistenceInstanceWriter

All Implemented Interfaces:

PersistenceInstanceWriter, AutoCloseable

public class DefaultPersistenceInstanceWriter
extends TransactedPersistenceInstanceWriter

Field Summary

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

CLOUD_EVENT_IDS

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DefaultPersistenceInstanceWriter(PersistenceInstanceStore store, PersistenceExecutor persistenceExecutor)

Method Summary

Modifier and Type	Method	Description
protected void	doTransaction(Consumer<PersistenceInstanceOperations> operation, io.serverlessworkflow.impl.WorkflowDefinitionData definition)
protected PersistenceExecutor	persistenceExecutor()

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

close, doCompleteInstance, doStartInstance, doTransaction

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

DefaultPersistenceInstanceWriter

protected DefaultPersistenceInstanceWriter(PersistenceInstanceStore store,
 PersistenceExecutor persistenceExecutor)

Method Details

doTransaction

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

Specified by:

doTransaction in class TransactedPersistenceInstanceWriter

persistenceExecutor

protected PersistenceExecutor persistenceExecutor()

Specified by:

persistenceExecutor in class TransactedPersistenceInstanceWriter