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 and Description
static class	AssociationState.QuarantinedTimestamp
static class	AssociationState.QuarantinedTimestamp$

Constructor Summary

Constructors

Constructor and Description
AssociationState(int incarnation, scala.concurrent.Promise<UniqueAddress> uniqueRemoteAddressPromise, ImmutableLongMap<AssociationState.QuarantinedTimestamp> quarantined)

Method Summary

Modifier and Type	Method and Description
static AssociationState	apply()
int	incarnation()
boolean	isQuarantined()
boolean	isQuarantined(long uid)
AssociationState	newIncarnation(scala.concurrent.Promise<UniqueAddress> remoteAddressPromise)
AssociationState	newQuarantined()
ImmutableLongMap<AssociationState.QuarantinedTimestamp>	quarantined()
java.lang.String	toString()
scala.concurrent.Future<UniqueAddress>	uniqueRemoteAddress() Full outbound address with UID for this association.
scala.concurrent.Promise<UniqueAddress>	uniqueRemoteAddressPromise()
scala.Option<UniqueAddress>	uniqueRemoteAddressValue()

Methods inherited from class java.lang.Object

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

Constructor Detail

AssociationState

public AssociationState(int incarnation,
                        scala.concurrent.Promise<UniqueAddress> uniqueRemoteAddressPromise,
                        ImmutableLongMap<AssociationState.QuarantinedTimestamp> quarantined)

Method Detail

apply

public static AssociationState apply()

incarnation

public int incarnation()

uniqueRemoteAddressPromise

public scala.concurrent.Promise<UniqueAddress> uniqueRemoteAddressPromise()

quarantined

public ImmutableLongMap<AssociationState.QuarantinedTimestamp> quarantined()

uniqueRemoteAddress

public scala.concurrent.Future<UniqueAddress> uniqueRemoteAddress()

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

Returns:

(undocumented)

uniqueRemoteAddressValue

public scala.Option<UniqueAddress> uniqueRemoteAddressValue()

newIncarnation

public AssociationState newIncarnation(scala.concurrent.Promise<UniqueAddress> remoteAddressPromise)

newQuarantined

public AssociationState newQuarantined()

isQuarantined

public boolean isQuarantined()

isQuarantined

public boolean isQuarantined(long uid)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object