Package akka.remote.artery

Class AssociationState

java.lang.Object

akka.remote.artery.AssociationState

public final class AssociationState
extends java.lang.Object

Full outbound address with UID for this association. Completed by the handshake.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AssociationState.QuarantinedTimestamp
static class	AssociationState.QuarantinedTimestamp$

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

Modifier and Type	Method	Description
void	addUniqueRemoteAddressListener(scala.Function1<UniqueAddress,scala.runtime.BoxedUnit> callback)
static AssociationState	apply()
void	completeUniqueRemoteAddress(UniqueAddress peer)
OptionVal<SharedKillSwitch>	controlIdleKillSwitch()
int	incarnation()
boolean	isQuarantined()
boolean	isQuarantined(long uid)
java.util.concurrent.atomic.AtomicLong	lastUsedTimestamp()
AssociationState	newIncarnation(UniqueAddress remoteAddress)
AssociationState	newQuarantined()
ImmutableLongMap<AssociationState.QuarantinedTimestamp>	quarantined()
void	removeUniqueRemoteAddressListener(scala.Function1<UniqueAddress,scala.runtime.BoxedUnit> callback)
java.lang.String	toString()
scala.Option<UniqueAddress>	uniqueRemoteAddress()
AssociationState	withControlIdleKillSwitch(OptionVal<SharedKillSwitch> killSwitch)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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()

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()

isQuarantined

public boolean isQuarantined()

isQuarantined

public boolean isQuarantined(long uid)

withControlIdleKillSwitch

public AssociationState withControlIdleKillSwitch(OptionVal<SharedKillSwitch> killSwitch)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object