akka.remote
Class EndpointManager.EndpointRegistry

java.lang.Object
  extended by akka.remote.EndpointManager.EndpointRegistry
Enclosing class:
EndpointManager

public static class EndpointManager.EndpointRegistry
extends java.lang.Object


Constructor Summary
EndpointManager.EndpointRegistry()
           
 
Method Summary
 scala.Option<Address> addressForWriter(ActorRef writer)
           
 scala.collection.Iterable<ActorRef> allEndpoints()
           
 boolean hasWritableEndpointFor(Address address)
           
 boolean isQuarantined(Address address, int uid)
           
 boolean isReadOnly(ActorRef endpoint)
           
 boolean isWritable(ActorRef endpoint)
           
 void markAsFailed(ActorRef endpoint, scala.concurrent.duration.Deadline timeOfRelease)
          Marking an endpoint as failed means that we will not try to connect to the remote system within the gated period but it is ok for the remote system to try to connect to us.
 void markAsQuarantined(Address address, int uid, scala.concurrent.duration.Deadline timeOfRelease)
           
 void prune()
           
 scala.Option<scala.Tuple2<ActorRef,java.lang.Object>> readOnlyEndpointFor(Address address)
           
 scala.Option<java.lang.Object> refuseUid(Address address)
           
 ActorRef registerReadOnlyEndpoint(Address address, ActorRef endpoint, int uid)
           
 ActorRef registerWritableEndpoint(Address address, scala.Option<java.lang.Object> uid, scala.Option<java.lang.Object> refuseUid, ActorRef endpoint)
           
 void registerWritableEndpointUid(Address remoteAddress, int uid)
           
 void removePolicy(Address address)
           
 void unregisterEndpoint(ActorRef endpoint)
           
 scala.Option<EndpointManager.EndpointPolicy> writableEndpointWithPolicyFor(Address address)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

EndpointManager.EndpointRegistry

public EndpointManager.EndpointRegistry()
Method Detail

registerWritableEndpoint

public ActorRef registerWritableEndpoint(Address address,
                                         scala.Option<java.lang.Object> uid,
                                         scala.Option<java.lang.Object> refuseUid,
                                         ActorRef endpoint)

registerWritableEndpointUid

public void registerWritableEndpointUid(Address remoteAddress,
                                        int uid)

registerReadOnlyEndpoint

public ActorRef registerReadOnlyEndpoint(Address address,
                                         ActorRef endpoint,
                                         int uid)

unregisterEndpoint

public void unregisterEndpoint(ActorRef endpoint)

addressForWriter

public scala.Option<Address> addressForWriter(ActorRef writer)

writableEndpointWithPolicyFor

public scala.Option<EndpointManager.EndpointPolicy> writableEndpointWithPolicyFor(Address address)

hasWritableEndpointFor

public boolean hasWritableEndpointFor(Address address)

readOnlyEndpointFor

public scala.Option<scala.Tuple2<ActorRef,java.lang.Object>> readOnlyEndpointFor(Address address)

isWritable

public boolean isWritable(ActorRef endpoint)

isReadOnly

public boolean isReadOnly(ActorRef endpoint)

isQuarantined

public boolean isQuarantined(Address address,
                             int uid)

refuseUid

public scala.Option<java.lang.Object> refuseUid(Address address)

markAsFailed

public void markAsFailed(ActorRef endpoint,
                         scala.concurrent.duration.Deadline timeOfRelease)
Marking an endpoint as failed means that we will not try to connect to the remote system within the gated period but it is ok for the remote system to try to connect to us.

Parameters:
endpoint - (undocumented)
timeOfRelease - (undocumented)

markAsQuarantined

public void markAsQuarantined(Address address,
                              int uid,
                              scala.concurrent.duration.Deadline timeOfRelease)

removePolicy

public void removePolicy(Address address)

allEndpoints

public scala.collection.Iterable<ActorRef> allEndpoints()

prune

public void prune()