io.eventuate.tram.sagas.simpledsl

Class ParticipantInvocationImpl<Data,C extends io.eventuate.tram.commands.common.Command>

java.lang.Object

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

io.eventuate.tram.sagas.simpledsl.ParticipantInvocationImpl<Data,C>

All Implemented Interfaces:

ParticipantInvocation<Data>

public class ParticipantInvocationImpl<Data,C extends io.eventuate.tram.commands.common.Command>
extends AbstractParticipantInvocation<Data>

Constructor Summary

Constructors

Constructor and Description
ParticipantInvocationImpl(java.util.Optional<java.util.function.Predicate<Data>> invocablePredicate, java.util.function.Function<Data,io.eventuate.tram.commands.consumer.CommandWithDestination> commandBuilder)

Method Summary

Modifier and Type	Method and Description
boolean	isSuccessfulReply(io.eventuate.tram.messaging.common.Message message)
io.eventuate.tram.commands.consumer.CommandWithDestination	makeCommandToSend(Data data)

Methods inherited from class io.eventuate.tram.sagas.simpledsl.AbstractParticipantInvocation

isInvocable

Methods inherited from class java.lang.Object

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

Constructor Detail

ParticipantInvocationImpl

public ParticipantInvocationImpl(java.util.Optional<java.util.function.Predicate<Data>> invocablePredicate,
                                 java.util.function.Function<Data,io.eventuate.tram.commands.consumer.CommandWithDestination> commandBuilder)

Method Detail

isSuccessfulReply

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

makeCommandToSend

public io.eventuate.tram.commands.consumer.CommandWithDestination makeCommandToSend(Data data)