io.eventuate.tram.sagas.testing.commandhandling

Class ReconfigurableCommandHandlers

java.lang.Object

io.eventuate.tram.commands.consumer.CommandHandlers

io.eventuate.tram.sagas.testing.commandhandling.ReconfigurableCommandHandlers

public class ReconfigurableCommandHandlers
extends io.eventuate.tram.commands.consumer.CommandHandlers

Constructor Summary

Constructors

Constructor and Description
ReconfigurableCommandHandlers(java.util.Set<java.lang.String> commandChannels)

Method Summary

Modifier and Type	Method and Description
void	add(SagaParticipantStubCommandHandler commandHandler)
<C extends io.eventuate.tram.commands.common.Command> java.util.Optional<SagaParticipantStubCommandHandler>	findCommandHandler(java.lang.String channel, java.lang.Class<C> commandClass)
java.util.Optional<io.eventuate.tram.commands.consumer.CommandExceptionHandler>	findExceptionHandler(java.lang.Throwable cause)
java.util.Optional<io.eventuate.tram.commands.consumer.CommandHandler>	findTargetMethod(io.eventuate.tram.messaging.common.Message message)
java.util.Set<java.lang.String>	getChannels()
void	reset()

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

getHandlers

Methods inherited from class java.lang.Object

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

Constructor Detail

ReconfigurableCommandHandlers

public ReconfigurableCommandHandlers(java.util.Set<java.lang.String> commandChannels)

Method Detail

getChannels

public java.util.Set<java.lang.String> getChannels()

Overrides:

getChannels in class io.eventuate.tram.commands.consumer.CommandHandlers

add

public void add(SagaParticipantStubCommandHandler commandHandler)

findTargetMethod

public java.util.Optional<io.eventuate.tram.commands.consumer.CommandHandler> findTargetMethod(io.eventuate.tram.messaging.common.Message message)

Overrides:

findTargetMethod in class io.eventuate.tram.commands.consumer.CommandHandlers

findExceptionHandler

public java.util.Optional<io.eventuate.tram.commands.consumer.CommandExceptionHandler> findExceptionHandler(java.lang.Throwable cause)

Overrides:

findExceptionHandler in class io.eventuate.tram.commands.consumer.CommandHandlers

reset

public void reset()

findCommandHandler

public <C extends io.eventuate.tram.commands.common.Command> java.util.Optional<SagaParticipantStubCommandHandler> findCommandHandler(java.lang.String channel,
                                                                                                                                      java.lang.Class<C> commandClass)