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)
Association
association(Address remoteAddress)
void
removeUnusedQuarantined(scala.concurrent.duration.FiniteDuration after)
Association
setUID(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
-
-