io.eventuate.tram.sagas.participant

Class SagaCommandHandlersBuilder

java.lang.Object

io.eventuate.tram.sagas.participant.SagaCommandHandlersBuilder

All Implemented Interfaces:

AbstractSagaCommandHandlersBuilder

public class SagaCommandHandlersBuilder
extends java.lang.Object
implements AbstractSagaCommandHandlersBuilder

Constructor Summary

Constructors

Constructor and Description
SagaCommandHandlersBuilder()

Method Summary

Modifier and Type	Method and Description
io.eventuate.tram.commands.consumer.CommandHandlers	build()
static SagaCommandHandlersBuilder	fromChannel(java.lang.String channel)
<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)

Methods inherited from class java.lang.Object

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

Constructor Detail

SagaCommandHandlersBuilder

public SagaCommandHandlersBuilder()

Method Detail

fromChannel

public static SagaCommandHandlersBuilder fromChannel(java.lang.String channel)

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

build

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