io.eventuate.tram.sagas.simpledsl

Class StepBuilder<Data>

java.lang.Object

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

All Implemented Interfaces:

WithCompensationBuilder<Data>

public class StepBuilder<Data>
extends java.lang.Object
implements WithCompensationBuilder<Data>

Constructor Summary

Constructors

Constructor and Description
StepBuilder(SimpleSagaDefinitionBuilder<Data> builder)

Method Summary

Modifier and Type	Method and Description
LocalStepBuilder<Data>	invokeLocal(java.util.function.Consumer<Data> localFunction)
<C extends io.eventuate.tram.commands.common.Command> InvokeParticipantStepBuilder<Data>	invokeParticipant(CommandEndpoint<C> commandEndpoint, java.util.function.Function<Data,C> commandProvider)
InvokeParticipantStepBuilder<Data>	invokeParticipant(java.util.function.Function<Data,io.eventuate.tram.commands.consumer.CommandWithDestination> action)
<C extends io.eventuate.tram.commands.common.Command> InvokeParticipantStepBuilder<Data>	invokeParticipant(java.util.function.Predicate<Data> participantInvocationPredicate, CommandEndpoint<C> commandEndpoint, java.util.function.Function<Data,C> commandProvider)
InvokeParticipantStepBuilder<Data>	invokeParticipant(java.util.function.Predicate<Data> participantInvocationPredicate, java.util.function.Function<Data,io.eventuate.tram.commands.consumer.CommandWithDestination> action)
<C extends io.eventuate.tram.commands.common.Command> InvokeParticipantStepBuilder<Data>	withCompensation(CommandEndpoint<C> commandEndpoint, java.util.function.Function<Data,C> commandProvider)
InvokeParticipantStepBuilder<Data>	withCompensation(java.util.function.Function<Data,io.eventuate.tram.commands.consumer.CommandWithDestination> compensation)
<C extends io.eventuate.tram.commands.common.Command> InvokeParticipantStepBuilder<Data>	withCompensation(java.util.function.Predicate<Data> compensationPredicate, CommandEndpoint<C> commandEndpoint, java.util.function.Function<Data,C> commandProvider)
InvokeParticipantStepBuilder<Data>	withCompensation(java.util.function.Predicate<Data> compensationPredicate, java.util.function.Function<Data,io.eventuate.tram.commands.consumer.CommandWithDestination> compensation)

Methods inherited from class java.lang.Object

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

Constructor Detail

StepBuilder

public StepBuilder(SimpleSagaDefinitionBuilder<Data> builder)

Method Detail

invokeLocal

public LocalStepBuilder<Data> invokeLocal(java.util.function.Consumer<Data> localFunction)

invokeParticipant

public InvokeParticipantStepBuilder<Data> invokeParticipant(java.util.function.Function<Data,io.eventuate.tram.commands.consumer.CommandWithDestination> action)

invokeParticipant

public InvokeParticipantStepBuilder<Data> invokeParticipant(java.util.function.Predicate<Data> participantInvocationPredicate,
                                                            java.util.function.Function<Data,io.eventuate.tram.commands.consumer.CommandWithDestination> action)

invokeParticipant

public <C extends io.eventuate.tram.commands.common.Command> InvokeParticipantStepBuilder<Data> invokeParticipant(CommandEndpoint<C> commandEndpoint,
                                                                                                                  java.util.function.Function<Data,C> commandProvider)

invokeParticipant

public <C extends io.eventuate.tram.commands.common.Command> InvokeParticipantStepBuilder<Data> invokeParticipant(java.util.function.Predicate<Data> participantInvocationPredicate,
                                                                                                                  CommandEndpoint<C> commandEndpoint,
                                                                                                                  java.util.function.Function<Data,C> commandProvider)

withCompensation

public InvokeParticipantStepBuilder<Data> withCompensation(java.util.function.Function<Data,io.eventuate.tram.commands.consumer.CommandWithDestination> compensation)

Specified by:

withCompensation in interface WithCompensationBuilder<Data>

withCompensation

public InvokeParticipantStepBuilder<Data> withCompensation(java.util.function.Predicate<Data> compensationPredicate,
                                                           java.util.function.Function<Data,io.eventuate.tram.commands.consumer.CommandWithDestination> compensation)

Specified by:

withCompensation in interface WithCompensationBuilder<Data>

withCompensation

public <C extends io.eventuate.tram.commands.common.Command> InvokeParticipantStepBuilder<Data> withCompensation(CommandEndpoint<C> commandEndpoint,
                                                                                                                 java.util.function.Function<Data,C> commandProvider)

Specified by:

withCompensation in interface WithCompensationBuilder<Data>

withCompensation

public <C extends io.eventuate.tram.commands.common.Command> InvokeParticipantStepBuilder<Data> withCompensation(java.util.function.Predicate<Data> compensationPredicate,
                                                                                                                 CommandEndpoint<C> commandEndpoint,
                                                                                                                 java.util.function.Function<Data,C> commandProvider)

Specified by:

withCompensation in interface WithCompensationBuilder<Data>