akka.persistence.multidc.javadsl

Interface SignalHandlerBuilder<Command,Event,State>

All Known Implementing Classes:

ByStateCommandHandlerBuilder, CommandHandlerBuilder

public interface SignalHandlerBuilder<Command,Event,State>

Not intended for user extension.

Method Summary

Modifier and Type	Method and Description
CommandHandler<Command,Event,State>	build() Build a command handler from the appended cases.
scala.collection.immutable.Map<java.lang.Class<?>,scala.Function3<CommandContextImpl,State,java.lang.Object,EffectImpl<Event,State>>>	buildSignalHandlers() INTERNAL API
SignalHandlerBuilder<Command,Event,State>	onReceiveTimeout(SignalHandler<akka.actor.ReceiveTimeout,Event,State> handler) Register message handler for ReceiveTimeout messages.
SignalHandlerBuilder<Command,Event,State>	onTerminated(SignalHandler<akka.actor.Terminated,Event,State> handler) Register message handler for Terminated messages.
<M> SignalHandlerBuilder<Command,Event,State>	onTimer(java.lang.Class<M> messageClass, SignalHandler<M,Event,State> handler) Register message handler for timer messages.
void	signalHandlers_$eq(scala.collection.immutable.Map<java.lang.Class<?>,SignalHandler<java.lang.Object,Event,State>> x$1)
scala.collection.immutable.Map<java.lang.Class<?>,SignalHandler<java.lang.Object,Event,State>>	signalHandlers()

Method Detail

build

CommandHandler<Command,Event,State> build()

Build a command handler from the appended cases. The returned handler will throw a MatchError if applied to a command that has no defined match.

The builder is reset to empty after build has been called.

Returns:

(undocumented)

buildSignalHandlers

scala.collection.immutable.Map<java.lang.Class<?>,scala.Function3<CommandContextImpl,State,java.lang.Object,EffectImpl<Event,State>>> buildSignalHandlers()

INTERNAL API

Returns:

(undocumented)

onReceiveTimeout

SignalHandlerBuilder<Command,Event,State> onReceiveTimeout(SignalHandler<akka.actor.ReceiveTimeout,Event,State> handler)

Register message handler for ReceiveTimeout messages. If a handler for ReceiveTimeout messages was previously defined this will replace the previous handler.

Parameters:

handler - (undocumented)

Returns:

(undocumented)

onTerminated

SignalHandlerBuilder<Command,Event,State> onTerminated(SignalHandler<akka.actor.Terminated,Event,State> handler)

Register message handler for Terminated messages. If a handler for Terminated messages was previously defined this will replace the previous handler.

Parameters:

handler - (undocumented)

Returns:

(undocumented)

onTimer

<M> SignalHandlerBuilder<Command,Event,State> onTimer(java.lang.Class<M> messageClass,
                                                      SignalHandler<M,Event,State> handler)

Register message handler for timer messages. Timers are started through getTimers on akka.persistence.multidc.javadsl.ReplicatedEntity#ActorContext. Adding a handler for a timer message class that was previously defined will replace the previous handler for that class.

Parameters:

messageClass - (undocumented)

handler - (undocumented)

Returns:

(undocumented)

signalHandlers

scala.collection.immutable.Map<java.lang.Class<?>,SignalHandler<java.lang.Object,Event,State>> signalHandlers()

signalHandlers_$eq

void signalHandlers_$eq(scala.collection.immutable.Map<java.lang.Class<?>,SignalHandler<java.lang.Object,Event,State>> x$1)