public interface SignalHandlerBuilder<Command,Event,State>
| 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() |
CommandHandler<Command,Event,State> build()
MatchError if applied to
a command that has no defined match.
The builder is reset to empty after build has been called.
scala.collection.immutable.Map<java.lang.Class<?>,scala.Function3<CommandContextImpl,State,java.lang.Object,EffectImpl<Event,State>>> buildSignalHandlers()
SignalHandlerBuilder<Command,Event,State> onReceiveTimeout(SignalHandler<akka.actor.ReceiveTimeout,Event,State> handler)
ReceiveTimeout messages.
If a handler for ReceiveTimeout messages was previously defined this will
replace the previous handler.handler - (undocumented)SignalHandlerBuilder<Command,Event,State> onTerminated(SignalHandler<akka.actor.Terminated,Event,State> handler)
Terminated messages.
If a handler for Terminated messages was previously defined this will
replace the previous handler.handler - (undocumented)<M> SignalHandlerBuilder<Command,Event,State> onTimer(java.lang.Class<M> messageClass, SignalHandler<M,Event,State> handler)
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.messageClass - (undocumented)handler - (undocumented)scala.collection.immutable.Map<java.lang.Class<?>,SignalHandler<java.lang.Object,Event,State>> signalHandlers()
void signalHandlers_$eq(scala.collection.immutable.Map<java.lang.Class<?>,SignalHandler<java.lang.Object,Event,State>> x$1)