Package akka.remote.artery
Class AssociationState
- java.lang.Object
-
- akka.remote.artery.AssociationState
-
public final class AssociationState extends java.lang.Object
INTERNAL API
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
AssociationState.QuarantinedTimestamp
static class
AssociationState.QuarantinedTimestamp$
static class
AssociationState.UidKnown$
static class
AssociationState.UidQuarantined$
static class
AssociationState.UidUnknown$
static interface
AssociationState.UniqueRemoteAddressState
-
Constructor Summary
Constructors Constructor Description AssociationState(int incarnation, java.util.concurrent.atomic.AtomicLong lastUsedTimestamp, OptionVal<SharedKillSwitch> controlIdleKillSwitch, ImmutableLongMap<AssociationState.QuarantinedTimestamp> quarantined, java.util.concurrent.atomic.AtomicReference<akka.remote.artery.AssociationState.UniqueRemoteAddressValue> _uniqueRemoteAddress)
-
Method Summary
-
-
-
Constructor Detail
-
AssociationState
public AssociationState(int incarnation, java.util.concurrent.atomic.AtomicLong lastUsedTimestamp, OptionVal<SharedKillSwitch> controlIdleKillSwitch, ImmutableLongMap<AssociationState.QuarantinedTimestamp> quarantined, java.util.concurrent.atomic.AtomicReference<akka.remote.artery.AssociationState.UniqueRemoteAddressValue> _uniqueRemoteAddress)
-
-
Method Detail
-
apply
public static AssociationState apply()
-
incarnation
public int incarnation()
-
lastUsedTimestamp
public java.util.concurrent.atomic.AtomicLong lastUsedTimestamp()
-
controlIdleKillSwitch
public OptionVal<SharedKillSwitch> controlIdleKillSwitch()
-
quarantined
public ImmutableLongMap<AssociationState.QuarantinedTimestamp> quarantined()
-
uniqueRemoteAddress
public scala.Option<UniqueAddress> uniqueRemoteAddress()
Full outbound address with UID for this association. Completed by the handshake.
-
uniqueRemoteAddressState
public AssociationState.UniqueRemoteAddressState uniqueRemoteAddressState()
-
isQuarantined
public boolean isQuarantined()
-
isQuarantined
public boolean isQuarantined(long uid)
-
completeUniqueRemoteAddress
public void completeUniqueRemoteAddress(UniqueAddress peer)
-
addUniqueRemoteAddressListener
public void addUniqueRemoteAddressListener(scala.Function1<UniqueAddress,scala.runtime.BoxedUnit> callback)
-
removeUniqueRemoteAddressListener
public void removeUniqueRemoteAddressListener(scala.Function1<UniqueAddress,scala.runtime.BoxedUnit> callback)
-
newIncarnation
public AssociationState newIncarnation(UniqueAddress remoteAddress)
-
newQuarantined
public AssociationState newQuarantined()
-
withControlIdleKillSwitch
public AssociationState withControlIdleKillSwitch(OptionVal<SharedKillSwitch> killSwitch)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-