io.eventuate.tram.sagas.simpledsl

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

java.lang.Object

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

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

All Implemented Interfaces:

ParticipantInvocation<Data>

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

Constructor Summary

Constructors

Constructor and Description
ParticipantEndpointInvocationImpl(java.util.Optional<java.util.function.Predicate<Data>> invocablePredicate, CommandEndpoint<C> commandEndpoint, java.util.function.Function<Data,C> commandProvider)

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

ParticipantEndpointInvocationImpl

public ParticipantEndpointInvocationImpl(java.util.Optional<java.util.function.Predicate<Data>> invocablePredicate,
                                         CommandEndpoint<C> commandEndpoint,
                                         java.util.function.Function<Data,C> commandProvider)

Method Detail

isSuccessfulReply

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

makeCommandToSend

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