akka.remote
Class EndpointManager.EndpointRegistry
java.lang.Object
akka.remote.EndpointManager.EndpointRegistry
- Enclosing class:
- EndpointManager
public static class EndpointManager.EndpointRegistry
- extends java.lang.Object
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 |
EndpointManager.EndpointRegistry
public EndpointManager.EndpointRegistry()
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()