Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
Aaronontheweb authored and Horusiath committed Jul 3, 2015
1 parent aa08143 commit d586190
Showing 1 changed file with 0 additions and 18 deletions.
18 changes: 0 additions & 18 deletions src/core/Akka.Remote/RemoteActorRefProvider.cs
Original file line number Diff line number Diff line change
Expand Up @@ -206,7 +206,6 @@ public IInternalActorRef ActorOf(ActorSystemImpl system, Props props, IInternalA
path.Elements.ToArray()).
WithUid(path.Uid);
var remoteRef = new RemoteActorRef(Transport, localAddress, rpath, supervisor, props, deployment);
remoteRef.Start();
return remoteRef;
}
catch (Exception ex)
Expand Down Expand Up @@ -255,23 +254,6 @@ public IActorRef RootGuardianAt(Address address)
Deploy.None);
}

private IInternalActorRef RemoteActorOf(ActorSystemImpl system, Props props, IInternalActorRef supervisor,
ActorPath path)
{
var scope = (RemoteScope)props.Deploy.Scope;
var d = props.Deploy;
var addr = scope.Address;

var localAddress = Transport.LocalAddressForRemote(addr);

var rpath = (new RootActorPath(addr) / "remote" / localAddress.Protocol / localAddress.HostPort() /
path.Elements.ToArray()).
WithUid(path.Uid);
var remoteRef = new RemoteActorRef(Transport, localAddress, rpath, supervisor, props, d);
remoteRef.Start();
return remoteRef;
}

private IInternalActorRef LocalActorOf(ActorSystemImpl system, Props props, IInternalActorRef supervisor,
ActorPath path, bool systemService, Deploy deploy, bool lookupDeploy, bool async)
{
Expand Down

0 comments on commit d586190

Please sign in to comment.