io.eventuate.tram.sagas.simpledsl

Class ParticipantInvocationStep<Data>

java.lang.Object

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

All Implemented Interfaces:

SagaStep<Data>

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

Constructor Summary

Constructors

Constructor and Description
ParticipantInvocationStep(java.util.Optional<ParticipantInvocation<Data>> participantInvocation, java.util.Optional<ParticipantInvocation<Data>> compensation, java.util.Map<java.lang.String,java.util.function.BiConsumer<Data,java.lang.Object>> actionReplyHandlers, java.util.Map<java.lang.String,java.util.function.BiConsumer<Data,java.lang.Object>> compensationReplyHandlers)

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

ParticipantInvocationStep

public ParticipantInvocationStep(java.util.Optional<ParticipantInvocation<Data>> participantInvocation,
                                 java.util.Optional<ParticipantInvocation<Data>> compensation,
                                 java.util.Map<java.lang.String,java.util.function.BiConsumer<Data,java.lang.Object>> actionReplyHandlers,
                                 java.util.Map<java.lang.String,java.util.function.BiConsumer<Data,java.lang.Object>> compensationReplyHandlers)

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>

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>

isSuccessfulReply

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

Specified by:

isSuccessfulReply in interface SagaStep<Data>

makeStepOutcome

public StepOutcome makeStepOutcome(Data data,
                                   boolean compensating)

Specified by:

makeStepOutcome in interface SagaStep<Data>