akka.persistence.multidc.internal

Class CommandHandlerImpl<Command,Event,State>

java.lang.Object

akka.persistence.multidc.javadsl.CommandHandler<Command,Event,State>

akka.persistence.multidc.internal.CommandHandlerImpl<Command,Event,State>

All Implemented Interfaces:

ReplicatedEntity.CommandHandler<Command,Event,State>

Direct Known Subclasses:

ByStateCommandHandlerImpl

public class CommandHandlerImpl<Command,Event,State>
extends CommandHandler<Command,Event,State>
implements ReplicatedEntity.CommandHandler<Command,Event,State>

Command handlers and optional functions for other signals, e.g. Termination messages if watch is used. CommandHandlerImpl is an immutable class.

Constructor Summary

Constructors

Constructor and Description
CommandHandlerImpl(scala.Function3<CommandContextImpl,State,Command,EffectImpl<Event,State>> commandHandler, scala.collection.immutable.Map<java.lang.Class<?>,scala.Function3<CommandContextImpl,State,java.lang.Object,EffectImpl<Event,State>>> signalHandlers)

Method Summary

Modifier and Type	Method and Description
scala.Function3<CommandContextImpl,State,Command,EffectImpl<Event,State>>	commandHandler()
CommandHandlerImpl<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> CommandHandlerImpl<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.
scala.Option<scala.Function3<CommandContextImpl,State,java.lang.Object,EffectImpl<Event,State>>>	signalHandler(State state, java.lang.Class<?> clazz)
CommandHandlerImpl<Command,Event,State>	withSameSignalHandlersAs(CommandHandlerImpl<Command,Event,State> other) Use the same onTerminated(scala.Function3<akka.persistence.multidc.scaladsl.ReplicatedEntity.CommandContext, State, akka.actor.Terminated, akka.persistence.multidc.scaladsl.Effect<Event, State>>), onReceiveTimeout(scala.Function2<akka.persistence.multidc.scaladsl.ReplicatedEntity.CommandContext, State, akka.persistence.multidc.scaladsl.Effect<Event, State>>), and onTimer(scala.Function3<akka.persistence.multidc.scaladsl.ReplicatedEntity.CommandContext, State, M, akka.persistence.multidc.scaladsl.Effect<Event, State>>, scala.reflect.ClassTag<M>) as defined by other.
CommandHandlerImpl<Command,Event,State>	withSignalHandlers(scala.collection.immutable.Map<java.lang.Class<?>,scala.Function3<CommandContextImpl,State,java.lang.Object,EffectImpl<Event,State>>> signalHandlers) INTERNAL API
scala.collection.immutable.Map<java.lang.Class<?>,scala.Function3<CommandContextImpl,State,java.lang.Object,EffectImpl<Event,State>>>	withSignalHandlers$default$1()

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandHandlerImpl

public CommandHandlerImpl(scala.Function3<CommandContextImpl,State,Command,EffectImpl<Event,State>> commandHandler,
                          scala.collection.immutable.Map<java.lang.Class<?>,scala.Function3<CommandContextImpl,State,java.lang.Object,EffectImpl<Event,State>>> signalHandlers)

Method Detail

commandHandler

public scala.Function3<CommandContextImpl,State,Command,EffectImpl<Event,State>> commandHandler()

signalHandler

public scala.Option<scala.Function3<CommandContextImpl,State,java.lang.Object,EffectImpl<Event,State>>> signalHandler(State state,
                                                                                                                      java.lang.Class<?> clazz)

onTerminated

public ReplicatedEntity.CommandHandler<Command,Event,State> onTerminated(scala.Function3<ReplicatedEntity.CommandContext,State,akka.actor.Terminated,Effect<Event,State>> handler)

Description copied from interface: ReplicatedEntity.CommandHandler

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

Specified by:

onTerminated in interface ReplicatedEntity.CommandHandler<Command,Event,State>

Parameters:

handler - (undocumented)

Returns:

(undocumented)

onReceiveTimeout

public CommandHandlerImpl<Command,Event,State> onReceiveTimeout(scala.Function2<ReplicatedEntity.CommandContext,State,Effect<Event,State>> handler)

Description copied from interface: ReplicatedEntity.CommandHandler

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

Specified by:

onReceiveTimeout in interface ReplicatedEntity.CommandHandler<Command,Event,State>

Parameters:

handler - (undocumented)

Returns:

(undocumented)

onTimer

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

Description copied from interface: ReplicatedEntity.CommandHandler

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.

Specified by:

onTimer in interface ReplicatedEntity.CommandHandler<Command,Event,State>

Parameters:

handler - (undocumented)

evidence$1 - (undocumented)

Returns:

(undocumented)

withSignalHandlers

public CommandHandlerImpl<Command,Event,State> withSignalHandlers(scala.collection.immutable.Map<java.lang.Class<?>,scala.Function3<CommandContextImpl,State,java.lang.Object,EffectImpl<Event,State>>> signalHandlers)

INTERNAL API

Parameters:

signalHandlers - (undocumented)

Returns:

(undocumented)

withSignalHandlers$default$1

public scala.collection.immutable.Map<java.lang.Class<?>,scala.Function3<CommandContextImpl,State,java.lang.Object,EffectImpl<Event,State>>> withSignalHandlers$default$1()

withSameSignalHandlersAs

public CommandHandlerImpl<Command,Event,State> withSameSignalHandlersAs(CommandHandlerImpl<Command,Event,State> other)

Use the same onTerminated(scala.Function3<akka.persistence.multidc.scaladsl.ReplicatedEntity.CommandContext, State, akka.actor.Terminated, akka.persistence.multidc.scaladsl.Effect<Event, State>>), onReceiveTimeout(scala.Function2<akka.persistence.multidc.scaladsl.ReplicatedEntity.CommandContext, State, akka.persistence.multidc.scaladsl.Effect<Event, State>>), and onTimer(scala.Function3<akka.persistence.multidc.scaladsl.ReplicatedEntity.CommandContext, State, M, akka.persistence.multidc.scaladsl.Effect<Event, State>>, scala.reflect.ClassTag<M>) as defined by other.

Parameters:

other - (undocumented)

Returns:

(undocumented)