io.eventuate.tram.sagas.participant

Class SagaCommandHandlerBuilder<C>

java.lang.Object

io.eventuate.tram.sagas.participant.SagaCommandHandlerBuilder<C>

All Implemented Interfaces:

AbstractSagaCommandHandlersBuilder

public class SagaCommandHandlerBuilder<C>
extends java.lang.Object
implements AbstractSagaCommandHandlersBuilder

Constructor Summary

Constructors

Constructor and Description
SagaCommandHandlerBuilder(SagaCommandHandlersBuilder parent, SagaCommandHandler h)

Method Summary

Modifier and Type	Method and Description
io.eventuate.tram.commands.consumer.CommandHandlers	build()
<C> SagaCommandHandlerBuilder<C>	onMessage(java.lang.Class<C> commandClass, java.util.function.Consumer<io.eventuate.tram.commands.consumer.CommandMessage<C>> handler)
<C> SagaCommandHandlerBuilder<C>	onMessage(java.lang.Class<C> commandClass, java.util.function.Function<io.eventuate.tram.commands.consumer.CommandMessage<C>,io.eventuate.tram.messaging.common.Message> handler)
<C> SagaCommandHandlerBuilder<C>	onMessageReturningMessages(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)
<C> SagaCommandHandlerBuilder<C>	onMessageReturningOptionalMessage(java.lang.Class<C> commandClass, java.util.function.Function<io.eventuate.tram.commands.consumer.CommandMessage<C>,java.util.Optional<io.eventuate.tram.messaging.common.Message>> handler)
SagaCommandHandlerBuilder<C>	withPostLock(PostLockFunction<C> postLock)
SagaCommandHandlerBuilder<C>	withPreLock(java.util.function.BiFunction<io.eventuate.tram.commands.consumer.CommandMessage<C>,io.eventuate.tram.commands.consumer.PathVariables,LockTarget> preLock)

Methods inherited from class java.lang.Object

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

Constructor Detail

SagaCommandHandlerBuilder

public SagaCommandHandlerBuilder(SagaCommandHandlersBuilder parent,
                                 SagaCommandHandler h)

Method Detail

onMessageReturningMessages

public <C> SagaCommandHandlerBuilder<C> onMessageReturningMessages(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)

Specified by:

onMessageReturningMessages in interface AbstractSagaCommandHandlersBuilder

onMessageReturningOptionalMessage

public <C> SagaCommandHandlerBuilder<C> onMessageReturningOptionalMessage(java.lang.Class<C> commandClass,
                                                                          java.util.function.Function<io.eventuate.tram.commands.consumer.CommandMessage<C>,java.util.Optional<io.eventuate.tram.messaging.common.Message>> handler)

Specified by:

onMessageReturningOptionalMessage in interface AbstractSagaCommandHandlersBuilder

onMessage

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

Specified by:

onMessage in interface AbstractSagaCommandHandlersBuilder

onMessage

public <C> SagaCommandHandlerBuilder<C> onMessage(java.lang.Class<C> commandClass,
                                                  java.util.function.Consumer<io.eventuate.tram.commands.consumer.CommandMessage<C>> handler)

Specified by:

onMessage in interface AbstractSagaCommandHandlersBuilder

withPreLock

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

withPostLock

public SagaCommandHandlerBuilder<C> withPostLock(PostLockFunction<C> postLock)

build

public io.eventuate.tram.commands.consumer.CommandHandlers build()