io.eventuate.tram.sagas.participant

Class SagaCommandHandler

java.lang.Object

io.eventuate.tram.commands.consumer.CommandHandler

io.eventuate.tram.sagas.participant.SagaCommandHandler

public class SagaCommandHandler
extends io.eventuate.tram.commands.consumer.CommandHandler

Constructor Summary

Constructors

Constructor and Description
SagaCommandHandler(java.lang.String channel, java.lang.Class<C> commandClass, java.util.function.Function<io.eventuate.tram.commands.consumer.CommandMessage<C>,java.util.List<io.eventuate.tram.messaging.common.Message>> handler)
SagaCommandHandler(java.lang.String channel, java.lang.String resource, java.lang.Class<C> commandClass, java.util.function.BiFunction<io.eventuate.tram.commands.consumer.CommandMessage<C>,io.eventuate.tram.commands.consumer.PathVariables,java.util.List<io.eventuate.tram.messaging.common.Message>> handler)

Method Summary

Modifier and Type	Method and Description
java.util.Optional<PostLockFunction>	getPostLock()
java.util.Optional<java.util.function.BiFunction<io.eventuate.tram.commands.consumer.CommandMessage,io.eventuate.tram.commands.consumer.PathVariables,LockTarget>>	getPreLock()
void	setPostLock(PostLockFunction postLock)
void	setPreLock(java.util.function.BiFunction<io.eventuate.tram.commands.consumer.CommandMessage,io.eventuate.tram.commands.consumer.PathVariables,LockTarget> preLock)

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

getChannel, getCommandClass, getResource, handles, invokeMethod

Methods inherited from class java.lang.Object

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

Constructor Detail

SagaCommandHandler

public SagaCommandHandler(java.lang.String channel,
                          java.lang.String resource,
                          java.lang.Class<C> commandClass,
                          java.util.function.BiFunction<io.eventuate.tram.commands.consumer.CommandMessage<C>,io.eventuate.tram.commands.consumer.PathVariables,java.util.List<io.eventuate.tram.messaging.common.Message>> handler)

SagaCommandHandler

public SagaCommandHandler(java.lang.String channel,
                          java.lang.Class<C> commandClass,
                          java.util.function.Function<io.eventuate.tram.commands.consumer.CommandMessage<C>,java.util.List<io.eventuate.tram.messaging.common.Message>> handler)

Method Detail

setPreLock

public void setPreLock(java.util.function.BiFunction<io.eventuate.tram.commands.consumer.CommandMessage,io.eventuate.tram.commands.consumer.PathVariables,LockTarget> preLock)

setPostLock

public void setPostLock(PostLockFunction postLock)

getPreLock

public java.util.Optional<java.util.function.BiFunction<io.eventuate.tram.commands.consumer.CommandMessage,io.eventuate.tram.commands.consumer.PathVariables,LockTarget>> getPreLock()

getPostLock

public java.util.Optional<PostLockFunction> getPostLock()