public static class EndpointManager.EndpointRegistry
extends java.lang.Object
Constructor and Description |
---|
EndpointRegistry() |
Modifier and Type | Method and 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,
scala.Option<java.lang.Object> refuseUid,
ActorRef endpoint) |
void |
registerWritableEndpointRefuseUid(Address remoteAddress,
int refuseUid) |
void |
registerWritableEndpointUid(Address remoteAddress,
int uid) |
void |
removePolicy(Address address) |
void |
unregisterEndpoint(ActorRef endpoint) |
scala.Option<EndpointManager.EndpointPolicy> |
writableEndpointWithPolicyFor(Address address) |
public ActorRef registerWritableEndpoint(Address address, scala.Option<java.lang.Object> uid, scala.Option<java.lang.Object> refuseUid, ActorRef endpoint)
public void registerWritableEndpointUid(Address remoteAddress, int uid)
public void registerWritableEndpointRefuseUid(Address remoteAddress, int refuseUid)
public ActorRef registerReadOnlyEndpoint(Address address, ActorRef endpoint, int uid)
public void unregisterEndpoint(ActorRef endpoint)
public scala.Option<EndpointManager.EndpointPolicy> writableEndpointWithPolicyFor(Address address)
public boolean hasWritableEndpointFor(Address address)
public scala.Option<scala.Tuple2<ActorRef,java.lang.Object>> readOnlyEndpointFor(Address address)
public boolean isWritable(ActorRef endpoint)
public boolean isReadOnly(ActorRef endpoint)
public boolean isQuarantined(Address address, int uid)
public scala.Option<java.lang.Object> refuseUid(Address address)
public void markAsFailed(ActorRef endpoint, scala.concurrent.duration.Deadline timeOfRelease)
endpoint
- (undocumented)timeOfRelease
- (undocumented)public void markAsQuarantined(Address address, int uid, scala.concurrent.duration.Deadline timeOfRelease)
public void removePolicy(Address address)
public scala.collection.Iterable<ActorRef> allEndpoints()
public void prune()