Package akka.remote

Class EndpointManager.EndpointRegistry

  • Enclosing class:
    EndpointManager

    public static class EndpointManager.EndpointRegistry
    extends java.lang.Object
    • Constructor Detail

      • EndpointRegistry

        public EndpointRegistry()
    • Method Detail

      • addressForWriter

        public scala.Option<Address> addressForWriter​(ActorRef writer)
      • 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)