class

Movie::Remote::RemoteActorRef(T)

Inherits Movie::ActorRefBase < Reference < Object

RemoteActorRef provides a type-safe reference to an actor in a remote system. Messages sent through this reference are serialized and transmitted over TCP. Uses striped connection pools for parallel sending while preserving per-actor ordering.

Constants

Log = ::Log.for(self)

Constructors

new(system : Movie::AbstractActorSystem, pool : StripedConnectionPool, target_path : ActorPath, path_registry : Movie::PathRegistry)

Source

Instance methods

<<(message : T)

Sends a message to the remote actor (fire-and-forget).

Source

ask(message : T, response_type : R.class, timeout : Time::Span = 30.seconds) : Movie::Future(R) forall R

Performs an ask (request-reply) to the remote actor. Returns a Future that will be completed with the response.

Source

connection

Returns the connection being used for this actor ref.

Source

send_system(message : Movie::SystemMessage)

Sends a system message to the remote actor.

Source

target_path

Source

tell_from(sender : Movie::ActorRefBase | Nil, message : T)

Sends a message to the remote actor with sender information.

Source

tell_unordered(message : T)

Sends a message without ordering guarantee (uses round-robin for load balancing).

Source