class AssociationRegistry extends AnyRef
Shared state among pekko.remote.transport.TestTransport instances. Coordinates the transports and the means of communication between them.
- Source
- TestTransport.scala
- Alphabetic
- By Inheritance
- AssociationRegistry
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new AssociationRegistry()
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- Implicit
- This member is added by an implicit conversion from AssociationRegistry toany2stringadd[AssociationRegistry] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
- def ->[B](y: B): (AssociationRegistry, B)
- Implicit
- This member is added by an implicit conversion from AssociationRegistry toArrowAssoc[AssociationRegistry] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clearLog(): Unit
Clears the activity log.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- 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.
- def ensuring(cond: (AssociationRegistry) => Boolean, msg: => Any): AssociationRegistry
- Implicit
- This member is added by an implicit conversion from AssociationRegistry toEnsuring[AssociationRegistry] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: (AssociationRegistry) => Boolean): AssociationRegistry
- Implicit
- This member is added by an implicit conversion from AssociationRegistry toEnsuring[AssociationRegistry] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: Boolean, msg: => Any): AssociationRegistry
- Implicit
- This member is added by an implicit conversion from AssociationRegistry toEnsuring[AssociationRegistry] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: Boolean): AssociationRegistry
- Implicit
- This member is added by an implicit conversion from AssociationRegistry toEnsuring[AssociationRegistry] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- 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.
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- 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.
- localHandle
The handle
- returns
The option that contains the Future for the listener if exists.
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logActivity(activity: Activity): Unit
Logs a transport activity.
Logs a transport activity.
- activity
Activity to be logged.
- 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).
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- 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.
- 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.
- 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.
- def reset(): Unit
Resets the state of the registry.
Resets the state of the registry. Warning! This method is not atomic.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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.
- 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.
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)
- def formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from AssociationRegistry toStringFormat[AssociationRegistry] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @deprecated @inline()
- Deprecated
(Since version 2.12.16) Use
formatString.format(value)instead ofvalue.formatted(formatString), or use thef""string interpolator. In Java 15 and later,formattedresolves to the new method in String which has reversed parameters.
- def →[B](y: B): (AssociationRegistry, B)
- Implicit
- This member is added by an implicit conversion from AssociationRegistry toArrowAssoc[AssociationRegistry] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) Use
->instead. If you still wish to display it as one character, consider using a font with programming ligatures such as Fira Code.