Package akka.remote.artery
Class AssociationRegistry
- java.lang.Object
-
- akka.remote.artery.AssociationRegistry
-
public class AssociationRegistry extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description AssociationRegistry(scala.Function1<Address,Association> createAssociation)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.collection.immutable.Set<Association>allAssociations()OptionVal<Association>association(long uid)Associationassociation(Address remoteAddress)voidremoveUnusedQuarantined(scala.concurrent.duration.FiniteDuration after)AssociationsetUID(UniqueAddress peer)
-
-
-
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)
-
association
public OptionVal<Association> association(long uid)
-
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
-
-