Class PhobosRemoteActorRefProvider

Akka.Remote implementation of PhobosActorRefProvider

Inheritance

System.Object

Phobos.Actor.Impl.WrappedActorRefProvider

PhobosActorRefProvider

PhobosRemoteActorRefProvider

PhobosClusterActorRefProvider

Implements

IPhobosActorRefProvider

Akka.Remote.IRemoteActorRefProvider

IActorRefProvider

Inherited Members

PhobosActorRefProvider.Tracer

PhobosActorRefProvider.Monitor

PhobosActorRefProvider.Init(ActorSystemImpl)

PhobosActorRefProvider.AskTracingFilter

PhobosActorRefProvider.CreateFutureRef<T>(TaskCompletionSource<T>)

PhobosActorRefProvider.LocalDeploy(ActorSystemImpl, Props, IInternalActorRef, ActorPath, Boolean, Deploy, Boolean, Boolean)

System.Object.Equals(System.Object)

System.Object.Equals(System.Object, System.Object)

System.Object.GetHashCode()

System.Object.GetType()

System.Object.MemberwiseClone()

System.Object.ReferenceEquals(System.Object, System.Object)

System.Object.ToString()

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
System.String	systemName
Settings	settings
EventStream	eventStream

Properties

Rarp

Declaration

protected RemoteActorRefProvider Rarp { get; }

Property Value

Type	Description
Akka.Remote.RemoteActorRefProvider

RemoteDaemon

Declaration

public IInternalActorRef RemoteDaemon { get; }

Property Value

Type	Description
Akka.Actor.IInternalActorRef

RemoteSettings

Declaration

public RemoteSettings RemoteSettings { get; }

Property Value

Type	Description
RemoteSettings

RemoteWatcher

Declaration

public IActorRef RemoteWatcher { get; }

Property Value

Type	Description
IActorRef

Transport

Declaration

public RemoteTransport Transport { get; }

Property Value

Type	Description
Akka.Remote.RemoteTransport

Methods

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

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
Props	props
Akka.Actor.IInternalActorRef	supervisor
ActorPath	path
System.Boolean	systemService
Deploy	deploy
System.Boolean	lookupDeploy
System.Boolean	async

Returns

Type	Description
Akka.Actor.IInternalActorRef

Overrides

PhobosActorRefProvider.ActorOf(ActorSystemImpl, Props, IInternalActorRef, ActorPath, Boolean, Deploy, Boolean, Boolean)

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

PhobosActorRefProvider.CreateLog(IActorRefProvider, EventStream)

CreateUnderlying(String, Settings, EventStream)

Declaration

protected override IActorRefProvider CreateUnderlying(string systemName, Settings settings, EventStream eventStream)

Parameters

Type	Name	Description
System.String	systemName
Settings	settings
EventStream	eventStream

Returns

Type	Description
IActorRefProvider

Overrides

PhobosActorRefProvider.CreateUnderlying(String, Settings, EventStream)

HasAddress(Address)

Declaration

public bool HasAddress(Address address)

Parameters

Type	Name	Description
Address	address

Returns

Type	Description
System.Boolean

InternalResolveActorRef(String)

Declaration

public IActorRef InternalResolveActorRef(string path)

Parameters

Type	Name	Description
System.String	path

Returns

Type	Description
IActorRef

LookUpRemotes(IEnumerable<String>)

Declaration

public Deploy LookUpRemotes(IEnumerable<string> p)

Parameters

Type	Name	Description
System.Collections.Generic.IEnumerable<System.String>	p

Returns

Type	Description
Deploy

Quarantine(Address, Nullable<Int32>)

Declaration

public void Quarantine(Address address, int? uid)

Parameters

Type	Name	Description
Address	address
System.Nullable<System.Int32>	uid

ResolveActorRefWithLocalAddress(String, Address)

Declaration

public IInternalActorRef ResolveActorRefWithLocalAddress(string path, Address localAddress)

Parameters

Type	Name	Description
System.String	path
Address	localAddress

Returns

Type	Description
Akka.Actor.IInternalActorRef

UseActorOnNode(RemoteActorRef, Props, Deploy, IInternalActorRef)

Declaration

public void UseActorOnNode(RemoteActorRef actor, Props props, Deploy deploy, IInternalActorRef supervisor)

Parameters

Type	Name	Description
RemoteActorRef	actor
Props	props
Deploy	deploy
Akka.Actor.IInternalActorRef	supervisor

Implements

IPhobosActorRefProvider

Akka.Remote.IRemoteActorRefProvider

IActorRefProvider