Class AssociationRegistry


  • public class AssociationRegistry
    extends java.lang.Object
    INTERNAL API
    • Constructor Detail

      • AssociationRegistry

        public AssociationRegistry​(scala.Function1<Address,​Association> createAssociation)
    • Method Detail

      • allAssociations

        public scala.collection.immutable.Set<Association> allAssociations()
      • association

        public final Association association​(Address remoteAddress)
        Parameters:
        remoteAddress - (undocumented)
        Returns:
        (undocumented)
        Throws:
        ShuttingDown - if called while the transport is shutting down
      • removeUnusedQuarantined

        public void removeUnusedQuarantined​(scala.concurrent.duration.FiniteDuration after)
      • setUID

        public final Association setUID​(UniqueAddress peer)
        Parameters:
        peer - (undocumented)
        Returns:
        (undocumented)
        Throws:
        ShuttingDown - if called while the transport is shutting down