ReplicatedEntity

Type Members

trait ActorContext extends AnyRef

Actor context for ReplicatedEntity with somewhat limited capabilities and additional functionality specifically replicated entities.
Actor context for ReplicatedEntity with somewhat limited capabilities and additional functionality specifically replicated entities.
Not for user extension.

Annotations
@DoNotInherit()
trait CommandContext extends ActorContext

Actor context for ReplicatedEntity with somewhat limited capabilities and additional functionality specifically replicated entities.
Actor context for ReplicatedEntity with somewhat limited capabilities and additional functionality specifically replicated entities.
Replies are sent with the sender() ActorRef in the context or an ActorRef that is passed in the command.
Not for user extension.

Annotations
@DoNotInherit()
trait CommandHandler[Command, Event, State] extends AnyRef

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

Annotations
@DoNotInherit()
sealed class CommandHandlerFactories[Command, Event, State] extends AnyRef

CommandHandler defines how to react on a commands and optionally functions for other signals, e.g.
CommandHandler defines how to react on a commands and optionally functions for other signals, e.g. Termination messages if watch is used.
Note that you can have different handlers based on current state by using CommandHandler.byState.
Instances available through ReplicatedEntity.CommandHandler
Not for user extension.

Annotations
@DoNotInherit()
type CommandToEffect[Command, Event, State] = (CommandContext, State, Command) ⇒ Effect[Event, State]
trait EventTaggingContext extends AnyRef

Context passed to ReplicatedEntity.tagsFor when tagging events.
Context passed to ReplicatedEntity.tagsFor when tagging events.

Annotations
@DoNotInherit()
trait EventTriggerContext extends AnyRef

Context passed to ReplicatedEntity.eventTrigger.
Context passed to ReplicatedEntity.eventTrigger.

Annotations
@DoNotInherit()

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def clusterShardingProps[Command, Event, State](entityTypeName: String, entityFactory: () ⇒ ReplicatedEntity[Command, Event, State], settings: PersistenceMultiDcSettings)(implicit arg0: ClassTag[Command]): Props

The Props for the actor that can run a ReplicatedEntity with Cluster Sharding.
The Props for the actor that can run a ReplicatedEntity with Cluster Sharding.
entityTypeName
Use the same as the entity type name in Cluster Sharding. It is a prefix for the persistenceId, which is concatenated with the entityId and the data center identifier. Note that this can't be changed, since it is part of the storage key (persistenceId).
entityFactory
Factory for creating a new instance of the entity. It has to be a factory so that a new instance is created in case the actor is restarted.
settings
Configuration settings.
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def props[Command, Event, State](persistenceIdPrefix: String, entityId: String, entityFactory: () ⇒ ReplicatedEntity[Command, Event, State], settings: PersistenceMultiDcSettings)(implicit arg0: ClassTag[Command]): Props

The Props for the actor that can run a ReplicatedEntity.
The Props for the actor that can run a ReplicatedEntity.
Use #clusterShardingProps instead when using Cluster Sharding.
persistenceIdPrefix
Prefix for the persistenceId, which is concatenated with the entityId and the data center identifier. Empty string is a valid prefix if the entityId itself is globally unique. Note that this can't be changed, since it is part of the storage key (persistenceId).
entityId
The identifier of the entity. The persistenceId includes this entityId and is concatenated with persistenceIdPrefix and the data center identifier.
entityFactory
Factory for creating a new instance of the entity. It has to be a factory so that a new instance is created in case the actor is restarted.
settings
Configuration settings.
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Docs: class ReplicatedEntity | package scaladsl

object ReplicatedEntity

Type Members

trait ActorContext extends AnyRef

trait CommandContext extends ActorContext

trait CommandHandler[Command, Event, State] extends AnyRef

sealed class CommandHandlerFactories[Command, Event, State] extends AnyRef

type CommandToEffect[Command, Event, State] = (CommandContext, State, Command) ⇒ Effect[Event, State]

trait EventTaggingContext extends AnyRef

trait EventTriggerContext extends AnyRef

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

def clusterShardingProps[Command, Event, State](entityTypeName: String, entityFactory: () ⇒ ReplicatedEntity[Command, Event, State], settings: PersistenceMultiDcSettings)(implicit arg0: ClassTag[Command]): Props

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def props[Command, Event, State](persistenceIdPrefix: String, entityId: String, entityFactory: () ⇒ ReplicatedEntity[Command, Event, State], settings: PersistenceMultiDcSettings)(implicit arg0: ClassTag[Command]): Props

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from AnyRef

Inherited from Any

Ungrouped