Class PhobosRemoteActorRefProvider

Akka.Remote implementation of PhobosActorRefProvider

Inheritance
object
WrappedActorRefProvider
PhobosActorRefProvider
PhobosRemoteActorRefProvider
PhobosClusterActorRefProvider
Implements
IRemoteActorRefProvider
Inherited Members
Namespace: Phobos.Actor.Remote
Assembly: Phobos.Actor.Remote.dll
Syntax
public class PhobosRemoteActorRefProvider : PhobosActorRefProvider, IPhobosActorRefProvider, IRemoteActorRefProvider, IActorRefProvider

Constructors

PhobosRemoteActorRefProvider(string, Settings, EventStream)

Declaration
public PhobosRemoteActorRefProvider(string systemName, Settings settings, EventStream eventStream)
Parameters
Type Name Description
string systemName
Settings settings
EventStream eventStream

Properties

Rarp

Declaration
protected RemoteActorRefProvider Rarp { get; }
Property Value
Type Description
RemoteActorRefProvider

RemoteDaemon

Remoting system daemon responsible for powering remote deployment capabilities.

Declaration
public IInternalActorRef RemoteDaemon { get; }
Property Value
Type Description
IInternalActorRef

RemoteSettings

The remoting settings

Declaration
public RemoteSettings RemoteSettings { get; }
Property Value
Type Description
RemoteSettings

RemoteWatcher

The remote death watcher.

Declaration
public IActorRef RemoteWatcher { get; }
Property Value
Type Description
IActorRef

Transport

The remote transport. Wraps all of the underlying physical network transports.

Declaration
public RemoteTransport Transport { get; }
Property Value
Type Description
RemoteTransport

Methods

ActorOf(ActorSystemImpl, Props, IInternalActorRef, ActorPath, bool, Deploy, bool, bool)

Actor factory with create-only semantics: will create an actor as described by props with the given supervisor and path (may be different in case of remote supervision). If systemService is true, deployment is bypassed (local-only). If a value fordeploy is passed in, it should be regarded as taking precedence over the nominally applicable settings, but it should be overridable from external configuration; the lookup of the latter can be suppressed by setting "lookupDeploy" to "false".

Declaration
public override IInternalActorRef ActorOf(ActorSystemImpl system, Props props, IInternalActorRef supervisor, ActorPath path, bool systemService, Deploy deploy, bool lookupDeploy, bool async)
Parameters
Type Name Description
ActorSystemImpl system

TBD
Props props

TBD
IInternalActorRef supervisor

TBD
ActorPath path

TBD
bool systemService

TBD
Deploy deploy

TBD
bool lookupDeploy

TBD
bool async

TBD
Returns
Type Description
IInternalActorRef

TBD
Overrides

CreateLog(IActorRefProvider, EventStream)

Declaration
protected override ILoggingAdapter CreateLog(IActorRefProvider underlying, EventStream stream = null)
Parameters
Type Name Description
IActorRefProvider underlying
EventStream stream
Returns
Type Description
ILoggingAdapter
Overrides

CreateUnderlying(string, Settings, EventStream)

Declaration
protected override IActorRefProvider CreateUnderlying(string systemName, Settings settings, EventStream eventStream)
Parameters
Type Name Description
string systemName
Settings settings
EventStream eventStream
Returns
Type Description
IActorRefProvider
Overrides

HasAddress(Address)

Determines if a particular network address is assigned to any of this ActorSystem's transports.

Declaration
public bool HasAddress(Address address)
Parameters
Type Name Description
Address address

The address to check.
Returns
Type Description
bool

true if the address is assigned to any bound transports; false otherwise.

InternalResolveActorRef(string)

INTERNAL API: this is used by the Akka.Remote.Serialization.ActorRefResolveCache via the public ResolveActorRef(string) method.

Declaration
public IActorRef InternalResolveActorRef(string path)
Parameters
Type Name Description
string path

The path of the actor we intend to resolve.
Returns
Type Description
IActorRef

An IActorRef if a match was found. Otherwise deadletters.

LookUpRemotes(IEnumerable<string>)

Looks up local overrides for remote deployments

Declaration
public Deploy LookUpRemotes(IEnumerable<string> p)
Parameters
Type Name Description
IEnumerable<string> p
Returns
Type Description
Deploy

Quarantine(Address, int?)

Marks a remote system as out of sync and prevents reconnects until the quarantine timeout elapses.

Declaration
public void Quarantine(Address address, int? uid)
Parameters
Type Name Description
Address address

Address of the remote system to be quarantined
int? uid

UID of the remote system, if the uid is not defined it will not be a strong quarantine but the current endpoint writer will be stopped (dropping system messages) and the address will be gated

ResolveActorRefWithLocalAddress(string, Address)

INTERNAL API.

Called in deserialization of incoming remote messages where the correct local address is known.

Declaration
public IInternalActorRef ResolveActorRefWithLocalAddress(string path, Address localAddress)
Parameters
Type Name Description
string path

TBD
Address localAddress

TBD
Returns
Type Description
IInternalActorRef

TBD

UseActorOnNode(RemoteActorRef, Props, Deploy, IInternalActorRef)

TBD

Declaration
public void UseActorOnNode(RemoteActorRef actor, Props props, Deploy deploy, IInternalActorRef supervisor)
Parameters
Type Name Description
RemoteActorRef actor

TBD
Props props

TBD
Deploy deploy

TBD
IInternalActorRef supervisor

TBD

Implements

Akka.Remote.IRemoteActorRefProvider