io.eventuate.tram.sagas.testing.commandhandling

Class SagaParticipantStubCommandHandler<C>

java.lang.Object

io.eventuate.tram.commands.consumer.CommandHandler

io.eventuate.tram.sagas.testing.commandhandling.SagaParticipantStubCommandHandler<C>

public class SagaParticipantStubCommandHandler<C>
extends io.eventuate.tram.commands.consumer.CommandHandler

Constructor Summary

Constructors

Constructor and Description
SagaParticipantStubCommandHandler(java.lang.String commandChannel, java.lang.Class<C> expectedCommandClass, java.util.function.Predicate<io.eventuate.tram.messaging.common.Message> expectedCommand, java.util.function.Function<io.eventuate.tram.commands.consumer.CommandMessage<C>,io.eventuate.tram.messaging.common.Message> replyBuilder)

Method Summary

Modifier and Type	Method and Description
boolean	handles(io.eventuate.tram.messaging.common.Message message)
<C extends io.eventuate.tram.commands.common.Command> boolean	handles(java.lang.String channel, java.lang.Class<C> commandClass)
java.util.List<io.eventuate.tram.messaging.common.Message>	invokeMethod(io.eventuate.tram.commands.consumer.CommandMessage cm, java.util.Map<java.lang.String,java.lang.String> pathVars)
void	verifyCommandReceived()

Methods inherited from class io.eventuate.tram.commands.consumer.CommandHandler

getChannel, getCommandClass, getResource

Methods inherited from class java.lang.Object

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

Constructor Detail

SagaParticipantStubCommandHandler

public SagaParticipantStubCommandHandler(java.lang.String commandChannel,
                                         java.lang.Class<C> expectedCommandClass,
                                         java.util.function.Predicate<io.eventuate.tram.messaging.common.Message> expectedCommand,
                                         java.util.function.Function<io.eventuate.tram.commands.consumer.CommandMessage<C>,io.eventuate.tram.messaging.common.Message> replyBuilder)

Method Detail

invokeMethod

public java.util.List<io.eventuate.tram.messaging.common.Message> invokeMethod(io.eventuate.tram.commands.consumer.CommandMessage cm,
                                                                               java.util.Map<java.lang.String,java.lang.String> pathVars)

Overrides:

invokeMethod in class io.eventuate.tram.commands.consumer.CommandHandler

handles

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

Overrides:

handles in class io.eventuate.tram.commands.consumer.CommandHandler

handles

public <C extends io.eventuate.tram.commands.common.Command> boolean handles(java.lang.String channel,
                                                                             java.lang.Class<C> commandClass)

verifyCommandReceived

public void verifyCommandReceived()