final class PersistentEntityRef[Command] extends NoSerializationVerificationNeeded

Commands are sent to a PersistentEntity using a PersistentEntityRef. It is retrieved with PersistentEntityRegistry#refFor.

Source
PersistentEntityRef.scala
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PersistentEntityRef
  2. NoSerializationVerificationNeeded
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new PersistentEntityRef(entityId: String, region: ActorRef, system: ActorSystem, askTimeout: FiniteDuration)

Value Members

  1. def ask[Cmd <: Command with ReplyType[_]](command: Cmd): Future[ask.Cmd.ReplyType]

    Send the command to the PersistentEntity.

    Send the command to the PersistentEntity. The returned Future will be completed with the reply from the PersistentEntity. The type of the reply is defined by the command (see PersistentEntity.ReplyType).

    The Future may also be completed with failure, sent by the PersistentEntity or a akka.pattern.AskTimeoutException if there is no reply within a timeout. The timeout can defined in configuration or overridden using #withAskTimeout.

  2. val entityId: String
  3. def toString(): String
    Definition Classes
    PersistentEntityRef → AnyRef → Any
  4. def withAskTimeout(timeout: FiniteDuration): PersistentEntityRef[Command]

    The timeout for #ask.

    The timeout for #ask. The timeout is by default defined in configuration but it can be adjusted for a specific PersistentEntityRef using this method. Note that this returns a new PersistentEntityRef instance with the given timeout (PersistentEntityRef is immutable).