io.eventuate.tram.sagas.simpledsl

Class LocalStep<Data>

java.lang.Object

io.eventuate.tram.sagas.simpledsl.LocalStep<Data>

All Implemented Interfaces:

SagaStep<Data>

public class LocalStep<Data>
extends java.lang.Object
implements SagaStep<Data>

Constructor Summary

Constructors

Constructor and Description
LocalStep(java.util.function.Consumer<Data> localFunction, java.util.Optional<java.util.function.Consumer<Data>> compensation)

Method Summary

Modifier and Type	Method and Description
java.util.Optional<java.util.function.BiConsumer<Data,java.lang.Object>>	getReplyHandler(io.eventuate.tram.messaging.common.Message message, boolean compensating)
boolean	hasAction(Data data)
boolean	hasCompensation(Data data)
boolean	isSuccessfulReply(boolean compensating, io.eventuate.tram.messaging.common.Message message)
StepOutcome	makeStepOutcome(Data data, boolean compensating)

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalStep

public LocalStep(java.util.function.Consumer<Data> localFunction,
                 java.util.Optional<java.util.function.Consumer<Data>> compensation)

Method Detail

hasAction

public boolean hasAction(Data data)

Specified by:

hasAction in interface SagaStep<Data>

hasCompensation

public boolean hasCompensation(Data data)

Specified by:

hasCompensation in interface SagaStep<Data>

isSuccessfulReply

public boolean isSuccessfulReply(boolean compensating,
                                 io.eventuate.tram.messaging.common.Message message)

Specified by:

isSuccessfulReply in interface SagaStep<Data>

getReplyHandler

public java.util.Optional<java.util.function.BiConsumer<Data,java.lang.Object>> getReplyHandler(io.eventuate.tram.messaging.common.Message message,
                                                                                                boolean compensating)

Specified by:

getReplyHandler in interface SagaStep<Data>

makeStepOutcome

public StepOutcome makeStepOutcome(Data data,
                                   boolean compensating)

Specified by:

makeStepOutcome in interface SagaStep<Data>