class

Movie::EventSourcingExtension

Inherits Movie::Extension < Reference < Object

Constructors

new(system : AbstractActorSystem, store_ref : Movie::ActorRef(Persistence::EventStoreMessage), store : Persistence::EventStoreClient, registry : Movie::ActorRef(Persistence::RegistryMessage), timeout : Time::Span = 5.seconds)
Source

Instance methods

get_entity_ref(persistence_id : Persistence::Id) : Movie::ActorRefBase
Source
get_entity_ref_as(type : T.class, persistence_id : Persistence::Id) : ActorRef(T) forall T
Source
register_entity(key : String, &factory : Persistence::Id, Persistence::EventStoreClient -> AbstractBehavior(T)) forall T
Source
register_entity(type : T.class, &factory : Persistence::Id, Persistence::EventStoreClient -> AbstractBehavior(U)) forall T, U
Source
stop

Called when the system is shutting down. Override to cleanup resources (close connections, stop services, etc.)

Source

Nested types