io.eventuate.tram.sagas.simpledsl

Class InvokeParticipantStepBuilder<Data>

java.lang.Object

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

All Implemented Interfaces:

WithCompensationBuilder<Data>

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

Constructor Summary

Constructors

Constructor and Description
InvokeParticipantStepBuilder(SimpleSagaDefinitionBuilder<Data> parent)

Method Summary

Modifier and Type	Method and Description
SagaDefinition<Data>	build()
<T> InvokeParticipantStepBuilder<Data>	onReply(java.lang.Class<T> replyClass, java.util.function.BiConsumer<Data,T> replyHandler)
StepBuilder<Data>	step()
<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

InvokeParticipantStepBuilder

public InvokeParticipantStepBuilder(SimpleSagaDefinitionBuilder<Data> parent)

Method Detail

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>

onReply

public <T> InvokeParticipantStepBuilder<Data> onReply(java.lang.Class<T> replyClass,
                                                      java.util.function.BiConsumer<Data,T> replyHandler)

step

public StepBuilder<Data> step()

build

public SagaDefinition<Data> build()