Package io.serverlessworkflow.impl.persistence

Class WorkflowPersistenceListener

java.lang.Object

io.serverlessworkflow.impl.persistence.WorkflowPersistenceListener

All Implemented Interfaces:

io.serverlessworkflow.impl.lifecycle.WorkflowExecutionCompletableListener, io.serverlessworkflow.impl.ServicePriority, AutoCloseable, Comparable<io.serverlessworkflow.impl.ServicePriority>

public class WorkflowPersistenceListener
extends Object
implements io.serverlessworkflow.impl.lifecycle.WorkflowExecutionCompletableListener

Field Summary

Fields inherited from interface io.serverlessworkflow.impl.ServicePriority

DEFAULT_PRIORITY

Constructor Summary

Constructors

Constructor	Description
WorkflowPersistenceListener(PersistenceInstanceWriter persistenceWriter)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<?>	onTaskCompleted(io.serverlessworkflow.impl.lifecycle.TaskCompletedEvent ev)
CompletableFuture<?>	onTaskRetried(io.serverlessworkflow.impl.lifecycle.TaskRetriedEvent ev)
CompletableFuture<?>	onTaskStarted(io.serverlessworkflow.impl.lifecycle.TaskStartedEvent ev)
CompletableFuture<?>	onWorkflowCancelled(io.serverlessworkflow.impl.lifecycle.WorkflowCancelledEvent ev)
CompletableFuture<?>	onWorkflowCompleted(io.serverlessworkflow.impl.lifecycle.WorkflowCompletedEvent ev)
CompletableFuture<?>	onWorkflowFailed(io.serverlessworkflow.impl.lifecycle.WorkflowFailedEvent ev)
CompletableFuture<?>	onWorkflowResumed(io.serverlessworkflow.impl.lifecycle.WorkflowResumedEvent ev)
CompletableFuture<?>	onWorkflowStarted(io.serverlessworkflow.impl.lifecycle.WorkflowStartedEvent ev)
CompletableFuture<?>	onWorkflowSuspended(io.serverlessworkflow.impl.lifecycle.WorkflowSuspendedEvent ev)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.serverlessworkflow.impl.ServicePriority

compareTo, priority

Methods inherited from interface io.serverlessworkflow.impl.lifecycle.WorkflowExecutionCompletableListener

close, onTaskCancelled, onTaskFailed, onTaskResumed, onTaskSuspended, onWorkflowStatusChanged

Constructor Details

WorkflowPersistenceListener

public WorkflowPersistenceListener(PersistenceInstanceWriter persistenceWriter)

Method Details

onWorkflowStarted

public CompletableFuture<?> onWorkflowStarted(io.serverlessworkflow.impl.lifecycle.WorkflowStartedEvent ev)

Specified by:

onWorkflowStarted in interface io.serverlessworkflow.impl.lifecycle.WorkflowExecutionCompletableListener

onWorkflowFailed

public CompletableFuture<?> onWorkflowFailed(io.serverlessworkflow.impl.lifecycle.WorkflowFailedEvent ev)

Specified by:

onWorkflowFailed in interface io.serverlessworkflow.impl.lifecycle.WorkflowExecutionCompletableListener

onWorkflowCancelled

public CompletableFuture<?> onWorkflowCancelled(io.serverlessworkflow.impl.lifecycle.WorkflowCancelledEvent ev)

Specified by:

onWorkflowCancelled in interface io.serverlessworkflow.impl.lifecycle.WorkflowExecutionCompletableListener

onWorkflowSuspended

public CompletableFuture<?> onWorkflowSuspended(io.serverlessworkflow.impl.lifecycle.WorkflowSuspendedEvent ev)

Specified by:

onWorkflowSuspended in interface io.serverlessworkflow.impl.lifecycle.WorkflowExecutionCompletableListener

onWorkflowResumed

public CompletableFuture<?> onWorkflowResumed(io.serverlessworkflow.impl.lifecycle.WorkflowResumedEvent ev)

Specified by:

onWorkflowResumed in interface io.serverlessworkflow.impl.lifecycle.WorkflowExecutionCompletableListener

onWorkflowCompleted

public CompletableFuture<?> onWorkflowCompleted(io.serverlessworkflow.impl.lifecycle.WorkflowCompletedEvent ev)

Specified by:

onWorkflowCompleted in interface io.serverlessworkflow.impl.lifecycle.WorkflowExecutionCompletableListener

onTaskStarted

public CompletableFuture<?> onTaskStarted(io.serverlessworkflow.impl.lifecycle.TaskStartedEvent ev)

Specified by:

onTaskStarted in interface io.serverlessworkflow.impl.lifecycle.WorkflowExecutionCompletableListener

onTaskCompleted

public CompletableFuture<?> onTaskCompleted(io.serverlessworkflow.impl.lifecycle.TaskCompletedEvent ev)

Specified by:

onTaskCompleted in interface io.serverlessworkflow.impl.lifecycle.WorkflowExecutionCompletableListener

onTaskRetried

public CompletableFuture<?> onTaskRetried(io.serverlessworkflow.impl.lifecycle.TaskRetriedEvent ev)

Specified by:

onTaskRetried in interface io.serverlessworkflow.impl.lifecycle.WorkflowExecutionCompletableListener