akka.persistence.multidc.scaladsl

Interface ReplicatedEntity.CommandHandler<Command,Event,State>

All Known Implementing Classes:

ByStateCommandHandlerImpl, CommandHandlerImpl

Enclosing class:

ReplicatedEntity<Command,Event,State>

public static interface ReplicatedEntity.CommandHandler<Command,Event,State>

Not for user extension. Instances are available through factory methods on the ReplicatedEntity.CommandHandler companion.

Method Summary

Modifier and Type	Method and Description
ReplicatedEntity.CommandHandler<Command,Event,State>	onReceiveTimeout(scala.Function2<ReplicatedEntity.CommandContext,State,Effect<Event,State>> handler) Register message handler for ReceiveTimeout messages.
ReplicatedEntity.CommandHandler<Command,Event,State>	onTerminated(scala.Function3<ReplicatedEntity.CommandContext,State,akka.actor.Terminated,Effect<Event,State>> handler) Register message handler for Terminated messages.
<M> ReplicatedEntity.CommandHandler<Command,Event,State>	onTimer(scala.Function3<ReplicatedEntity.CommandContext,State,M,Effect<Event,State>> handler, scala.reflect.ClassTag<M> evidence$1) Register message handler for timer messages.

Method Detail

onTerminated

ReplicatedEntity.CommandHandler<Command,Event,State> onTerminated(scala.Function3<ReplicatedEntity.CommandContext,State,akka.actor.Terminated,Effect<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)

onReceiveTimeout

ReplicatedEntity.CommandHandler<Command,Event,State> onReceiveTimeout(scala.Function2<ReplicatedEntity.CommandContext,State,Effect<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)

onTimer

<M> ReplicatedEntity.CommandHandler<Command,Event,State> onTimer(scala.Function3<ReplicatedEntity.CommandContext,State,M,Effect<Event,State>> handler,
                                                                 scala.reflect.ClassTag<M> evidence$1)

Register message handler for timer messages. Timers are started with ActorContext.timers. Adding a handler for a timer message class that was previously defined will replace the previous handler for that class.

Parameters:

handler - (undocumented)

evidence$1 - (undocumented)

Returns:

(undocumented)