Package akka.remote
Class EndpointManager.EndpointRegistry
- java.lang.Object
-
- akka.remote.EndpointManager.EndpointRegistry
-
- Enclosing class:
- EndpointManager
public static class EndpointManager.EndpointRegistry extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description EndpointRegistry()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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, ActorRef endpoint)
void
registerWritableEndpointRefuseUid(Address remoteAddress, int refuseUid, scala.concurrent.duration.Deadline timeOfRelease)
void
registerWritableEndpointUid(Address remoteAddress, int uid)
void
removePolicy(Address address)
void
unregisterEndpoint(ActorRef endpoint)
scala.Option<EndpointManager.EndpointPolicy>
writableEndpointWithPolicyFor(Address address)
-
-
-
Method Detail
-
allEndpoints
public scala.collection.Iterable<ActorRef> allEndpoints()
-
hasWritableEndpointFor
public boolean hasWritableEndpointFor(Address address)
-
isQuarantined
public boolean isQuarantined(Address address, int uid)
-
isReadOnly
public boolean isReadOnly(ActorRef endpoint)
-
isWritable
public boolean isWritable(ActorRef endpoint)
-
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)
-
prune
public void prune()
-
readOnlyEndpointFor
public scala.Option<scala.Tuple2<ActorRef,java.lang.Object>> readOnlyEndpointFor(Address address)
-
refuseUid
public scala.Option<java.lang.Object> refuseUid(Address address)
-
registerReadOnlyEndpoint
public ActorRef registerReadOnlyEndpoint(Address address, ActorRef endpoint, int uid)
-
registerWritableEndpoint
public ActorRef registerWritableEndpoint(Address address, scala.Option<java.lang.Object> uid, ActorRef endpoint)
-
registerWritableEndpointRefuseUid
public void registerWritableEndpointRefuseUid(Address remoteAddress, int refuseUid, scala.concurrent.duration.Deadline timeOfRelease)
-
registerWritableEndpointUid
public void registerWritableEndpointUid(Address remoteAddress, int uid)
-
removePolicy
public void removePolicy(Address address)
-
unregisterEndpoint
public void unregisterEndpoint(ActorRef endpoint)
-
writableEndpointWithPolicyFor
public scala.Option<EndpointManager.EndpointPolicy> writableEndpointWithPolicyFor(Address address)
-
-