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 and Description
EndpointRegistry()

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EndpointRegistry

public 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)

registerWritableEndpointRefuseUid

public void registerWritableEndpointRefuseUid(Address remoteAddress,
                                              int refuseUid)

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()