akka.remote.transport.TestTransport

AssociationRegistry

class AssociationRegistry extends AnyRef

Shared state among akka.remote.transport.TestTransport instances. Coordinates the transports and the means of communication between them.

Linear Supertypes
AnyRef, Any
Type Hierarchy Learn more about scaladoc diagrams
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. AssociationRegistry
  2. AnyRef
  3. Any
Implicitly
  1. by any2stringadd
  2. by any2stringfmt
  3. by any2ArrowAssoc
  4. by any2Ensuring
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new AssociationRegistry()

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. def +(other: String): String

    Implicit information
    This member is added by an implicit conversion from AssociationRegistry to StringAdd performed by method any2stringadd in scala.Predef.
    Definition Classes
    StringAdd

  5. def ->[B](y: B): (AssociationRegistry, B)

    Implicit information
    This member is added by an implicit conversion from AssociationRegistry to ArrowAssoc[AssociationRegistry] performed by method any2ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()

  6. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  7. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  8. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  9. def clearLog(): Unit

    Clears the activity log.

  10. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  11. def deregisterAssociation(key: (Address, Address)): Option[(HandleEventListener, HandleEventListener)]

    Removes an association.

    Removes an association.

    key

    Ordered pair of addresses representing an association. First element is the address of the initiator.

    returns

    The original entries.

  12. def ensuring(cond: (AssociationRegistry) ⇒ Boolean, msg: ⇒ Any): AssociationRegistry

    Implicit information
    This member is added by an implicit conversion from AssociationRegistry to Ensuring[AssociationRegistry] performed by method any2Ensuring in scala.Predef.
    Definition Classes
    Ensuring

  13. def ensuring(cond: (AssociationRegistry) ⇒ Boolean): AssociationRegistry

    Implicit information
    This member is added by an implicit conversion from AssociationRegistry to Ensuring[AssociationRegistry] performed by method any2Ensuring in scala.Predef.
    Definition Classes
    Ensuring

  14. def ensuring(cond: Boolean, msg: ⇒ Any): AssociationRegistry

    Implicit information
    This member is added by an implicit conversion from AssociationRegistry to Ensuring[AssociationRegistry] performed by method any2Ensuring in scala.Predef.
    Definition Classes
    Ensuring

  15. def ensuring(cond: Boolean): AssociationRegistry

    Implicit information
    This member is added by an implicit conversion from AssociationRegistry to Ensuring[AssociationRegistry] performed by method any2Ensuring in scala.Predef.
    Definition Classes
    Ensuring

  16. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  17. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  18. def existsAssociation(initiatorAddress: Address, remoteAddress: Address): Boolean

    Tests if an association was registered.

    Tests if an association was registered.

    initiatorAddress

    The initiator of the association.

    remoteAddress

    The other address of the association.

    returns

    True if there is an association for the given addresses.

  19. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  20. def formatted(fmtstr: String): String

    Implicit information
    This member is added by an implicit conversion from AssociationRegistry to StringFormat performed by method any2stringfmt in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()

  21. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  22. def getRemoteReadHandlerFor(localHandle: TestAssociationHandle): Option[HandleEventListener]

    Returns the event handler corresponding to the remote endpoint of the given local handle.

    Returns the event handler corresponding to the remote endpoint of the given local handle. In other words it returns the listener that will receive InboundPayload events when 

    write()

    is called on the given handle.

    write() }}}

    localHandle

    The handle

    returns

    The option that contains the Future for the listener if exists.

  23. def hashCode(): Int

    Definition Classes
    AnyRef → Any

  24. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  25. def logActivity(activity: Activity): Unit

    Logs a transport activity.

    Logs a transport activity.

    activity

    Activity to be logged.

  26. def logSnapshot: Seq[Activity]

    Takes a thread-safe snapshot of the current state of the activity log.

    Takes a thread-safe snapshot of the current state of the activity log.

    returns

    Collection containing activities ordered left-to-right according to time (first element is earliest).

  27. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  28. final def notify(): Unit

    Definition Classes
    AnyRef

  29. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  30. def registerListenerPair(key: (Address, Address), listeners: (HandleEventListener, HandleEventListener)): Unit

    Registers a Future of two handle event listeners corresponding to the two endpoints of an association.

    Registers a Future of two handle event listeners corresponding to the two endpoints of an association.

    key

    Ordered pair of addresses representing an association. First element must be the address of the initiator.

    listeners

    The future containing the listeners that will be responsible for handling the events of the two endpoints of the association. Elements in the pair must be in the same order as the addresses in the key parameter.

  31. def registerTransport(transport: TestTransport, associationEventListenerFuture: Future[AssociationEventListener]): Unit

    Records a mapping between an address and the corresponding (transport, associationEventListener) pair.

    Records a mapping between an address and the corresponding (transport, associationEventListener) pair.

    transport

    The transport that is to be registered. The address of this transport will be used as key.

    associationEventListenerFuture

    The future that will be completed with the listener that will handle the events for the given transport.

  32. def remoteListenerRelativeTo(handle: TestAssociationHandle, listenerPair: (HandleEventListener, HandleEventListener)): HandleEventListener

    Returns the remote endpoint for a pair of endpoints relative to the owner of the supplied handle.

    Returns the remote endpoint for a pair of endpoints relative to the owner of the supplied handle.

    handle

    the reference handle to determine the remote endpoint relative to

    listenerPair

    pair of listeners in initiator, receiver order.

    returns

  33. def reset(): Unit

    Resets the state of the registry.

    Resets the state of the registry. Warning! This method is not atomic.

  34. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  35. def toString(): String

    Definition Classes
    AnyRef → Any

  36. def transportFor(address: Address): Option[(TestTransport, Future[AssociationEventListener])]

    Returns the Transport bound to the given address.

    Returns the Transport bound to the given address.

    address

    The address bound to the transport.

    returns

    The transport if exists.

  37. def transportsReady(addresses: Address*): Boolean

    Indicates if all given transports were successfully registered.

    Indicates if all given transports were successfully registered. No associations can be established between transports that are not yet registered.

    addresses

    The listen addresses of transports that participate in the test case.

    returns

    True if all transports are successfully registered.

  38. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  39. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  40. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  41. def →[B](y: B): (AssociationRegistry, B)

    Implicit information
    This member is added by an implicit conversion from AssociationRegistry to ArrowAssoc[AssociationRegistry] performed by method any2ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Shadowed Implicit Value Members

  1. val self: Any

    Implicit information
    This member is added by an implicit conversion from AssociationRegistry to StringAdd performed by method any2stringadd in scala.Predef.
    Shadowing
    This implicitly inherited member is ambiguous. One or more implicitly inherited members have similar signatures, so calling this member may produce an ambiguous implicit conversion compiler error.
    To access this member you can use a type ascription:
    (associationRegistry: StringAdd).self
    Definition Classes
    StringAdd

  2. val self: Any

    Implicit information
    This member is added by an implicit conversion from AssociationRegistry to StringFormat performed by method any2stringfmt in scala.Predef.
    Shadowing
    This implicitly inherited member is ambiguous. One or more implicitly inherited members have similar signatures, so calling this member may produce an ambiguous implicit conversion compiler error.
    To access this member you can use a type ascription:
    (associationRegistry: StringFormat).self
    Definition Classes
    StringFormat

Deprecated Value Members

  1. def x: AssociationRegistry

    Implicit information
    This member is added by an implicit conversion from AssociationRegistry to ArrowAssoc[AssociationRegistry] performed by method any2ArrowAssoc in scala.Predef.
    Shadowing
    This implicitly inherited member is ambiguous. One or more implicitly inherited members have similar signatures, so calling this member may produce an ambiguous implicit conversion compiler error.
    To access this member you can use a type ascription:
    (associationRegistry: ArrowAssoc[AssociationRegistry]).x
    Definition Classes
    ArrowAssoc
    Annotations
    @deprecated
    Deprecated

    (Since version 2.10.0) Use leftOfArrow instead

  2. def x: AssociationRegistry

    Implicit information
    This member is added by an implicit conversion from AssociationRegistry to Ensuring[AssociationRegistry] performed by method any2Ensuring in scala.Predef.
    Shadowing
    This implicitly inherited member is ambiguous. One or more implicitly inherited members have similar signatures, so calling this member may produce an ambiguous implicit conversion compiler error.
    To access this member you can use a type ascription:
    (associationRegistry: Ensuring[AssociationRegistry]).x
    Definition Classes
    Ensuring
    Annotations
    @deprecated
    Deprecated

    (Since version 2.10.0) Use resultOfEnsuring instead

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from AssociationRegistry to StringAdd

Inherited by implicit conversion any2stringfmt from AssociationRegistry to StringFormat

Inherited by implicit conversion any2ArrowAssoc from AssociationRegistry to ArrowAssoc[AssociationRegistry]

Inherited by implicit conversion any2Ensuring from AssociationRegistry to Ensuring[AssociationRegistry]

Ungrouped