trait PersistentEntityRegistry extends AnyRef
At system startup all PersistentEntity classes must be registered here with PersistentEntityRegistry#register.
Later, com.lightbend.lagom.scaladsl.persistence.PersistentEntityRef can be
retrieved with PersistentEntityRegistry#refFor.
Commands are sent to a com.lightbend.lagom.scaladsl.persistence.PersistentEntity
using a PersistentEntityRef
.
- Alphabetic
- By Inheritance
- PersistentEntityRegistry
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
abstract
def
eventStream[Event <: AggregateEvent[Event]](aggregateTag: AggregateEventTag[Event], fromOffset: Offset): Source[EventStreamElement[Event], NotUsed]
A stream of the persistent events that have the given
aggregateTag
, e.g.A stream of the persistent events that have the given
aggregateTag
, e.g. all persistent events of allOrder
entities.The type of the offset is journal dependent, some journals use time-based UUID offsets, while others use sequence numbers. The passed in
fromOffset
must either be akka.persistence.query.NoOffset, or an offset that has previously been produced by this journal.The stream will begin with events starting after
fromOffset
. To resume an event stream, store theOffset
corresponding to the most recently processedEvent
, and pass that back as the value forfromOffset
to start the stream from events following that one.- Exceptions thrown
IllegalArgumentException
If thefromOffset
type is not supported by this journal.
-
abstract
def
refFor[P <: PersistentEntity](entityId: String)(implicit arg0: ClassTag[P]): PersistentEntityRef[refFor.P.Command]
Retrieve a com.lightbend.lagom.scaladsl.persistence.PersistentEntityRef for a given com.lightbend.lagom.scaladsl.persistence.PersistentEntity class and identifier.
Retrieve a com.lightbend.lagom.scaladsl.persistence.PersistentEntityRef for a given com.lightbend.lagom.scaladsl.persistence.PersistentEntity class and identifier. Commands are sent to a
PersistentEntity
using aPersistentEntityRef
. -
abstract
def
register(entityFactory: ⇒ PersistentEntity): Unit
At system startup all com.lightbend.lagom.scaladsl.persistence.PersistentEntity classes must be registered with this method.
At system startup all com.lightbend.lagom.scaladsl.persistence.PersistentEntity classes must be registered with this method.
The
entityFactory
will be called when a new entity instance is to be created. That will happen in another thread, so theentityFactory
must be thread-safe, e.g. not close over shared mutable state that is not thread-safe. -
abstract
def
gracefulShutdown(timeout: FiniteDuration): Future[Done]
No-op method that exists only for backward-compatibility reasons.
No-op method that exists only for backward-compatibility reasons. Lagom now uses Akka's CoordinatedShutdown to gracefully shut down all sharded entities, including Persistent Entities.
- returns
a completed
Future
- Annotations
- @deprecated
- Deprecated
(Since version 1.4.0) This method has no effect and no longer needs to be called
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from PersistentEntityRegistry to any2stringadd[PersistentEntityRegistry] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (PersistentEntityRegistry, B)
- Implicit
- This member is added by an implicit conversion from PersistentEntityRegistry to ArrowAssoc[PersistentEntityRegistry] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
ensuring(cond: (PersistentEntityRegistry) ⇒ Boolean, msg: ⇒ Any): PersistentEntityRegistry
- Implicit
- This member is added by an implicit conversion from PersistentEntityRegistry to Ensuring[PersistentEntityRegistry] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (PersistentEntityRegistry) ⇒ Boolean): PersistentEntityRegistry
- Implicit
- This member is added by an implicit conversion from PersistentEntityRegistry to Ensuring[PersistentEntityRegistry] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): PersistentEntityRegistry
- Implicit
- This member is added by an implicit conversion from PersistentEntityRegistry to Ensuring[PersistentEntityRegistry] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): PersistentEntityRegistry
- Implicit
- This member is added by an implicit conversion from PersistentEntityRegistry to Ensuring[PersistentEntityRegistry] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from PersistentEntityRegistry to StringFormat[PersistentEntityRegistry] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
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( ... ) @native()
-
def
→[B](y: B): (PersistentEntityRegistry, B)
- Implicit
- This member is added by an implicit conversion from PersistentEntityRegistry to ArrowAssoc[PersistentEntityRegistry] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc