abstract class Movie::PersistentEntityExtension(SM, S)

Direct Known Subclasses

Defined in:

movie/persistence/behaviors.cr

Constructors

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

Instance Method Summary

#get_entity_ref(persistence_id : Persistence::EntityId(T), fence : Persistence::ShardLeaseToken | Nil = nil) : ActorRef(T) forall T
#register_entity(entity_type : E.class, message_type : C.class, &factory : Persistence::Id, S -> AbstractBehavior(C)) : Persistence::EntityType(C) forall E, C
#stop
Called when the system is shutting down.

Instance methods inherited from class `Movie::Extension`

,

Constructor Detail

def self.new(system : AbstractActorSystem, store_ref : Movie::ActorRef(SM), store : S, registry : Movie::ActorRef(Persistence::RegistryMessage), timeout : Time::Span = 5.seconds) #

[View source]

Instance Method Detail

def get_entity_ref(persistence_id : Persistence::EntityId(T), fence : Persistence::ShardLeaseToken | Nil = nil) : ActorRef(T) forall T #

[View source]

def register_entity(entity_type : E.class, message_type : C.class, &factory : Persistence::Id, S -> AbstractBehavior(C)) : Persistence::EntityType(C) forall E, C #

[View source]

def stop #

Description copied from class Movie::Extension

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

[View source]