Package org.apache.pekko.remote.transport

Class TestAssociationHandle

java.lang.Object
org.apache.pekko.remote.transport.TestAssociationHandle
All Implemented Interfaces:
Serializable, AssociationHandle, scala.Equals, scala.Product
public final class TestAssociationHandle extends Object implements AssociationHandle, scala.Product, Serializable
Deprecated.
Classic remoting is deprecated, use Artery. Since Akka 2.6.0.
See Also:

  • Constructor Details

    • TestAssociationHandle

      public TestAssociationHandle(Address localAddress, Address remoteAddress, TestTransport transport, boolean inbound)
      Deprecated.

  • Method Details

    • apply

      public static TestAssociationHandle apply(Address localAddress, Address remoteAddress, TestTransport transport, boolean inbound)
      Deprecated.

    • unapply

      public static scala.Option<scala.Tuple4<Address,Address,TestTransport,Object>> unapply(TestAssociationHandle x$0)
      Deprecated.

    • localAddress

      public Address localAddress()
      Deprecated.
      Description copied from interface: AssociationHandle
      Address of the local endpoint.

      Specified by:
      localAddress in interface AssociationHandle
      Returns:
      Address of the local endpoint.

    • remoteAddress

      public Address remoteAddress()
      Deprecated.
      Description copied from interface: AssociationHandle
      Address of the remote endpoint.

      Specified by:
      remoteAddress in interface AssociationHandle
      Returns:
      Address of the remote endpoint.

    • transport

      public TestTransport transport()
      Deprecated.

    • inbound

      public boolean inbound()
      Deprecated.

    • writable

      public boolean writable()
      Deprecated.

    • writable_$eq

      public void writable_$eq(boolean x$1)
      Deprecated.

    • readHandlerPromise

      public scala.concurrent.Promise<AssociationHandle.HandleEventListener> readHandlerPromise()
      Deprecated.
      Description copied from interface: AssociationHandle
      The Promise returned by this call must be completed with an pekko.remote.transport.AssociationHandle.HandleEventListener to register a listener responsible for handling incoming payload. Until the listener is not registered the transport SHOULD buffer incoming messages.

      Specified by:
      readHandlerPromise in interface AssociationHandle
      Returns:
      Promise that must be completed with the listener responsible for handling incoming data.

    • write

      public boolean write(ByteString payload)
      Deprecated.
      Description copied from interface: AssociationHandle
      Asynchronously sends the specified payload to the remote endpoint. This method MUST be thread-safe as it might be called from different threads. This method MUST NOT block.

      Writes guarantee ordering of messages, but not their reception. The call to write returns with a Boolean indicating if the channel was ready for writes or not. A return value of false indicates that the channel is not yet ready for delivery (e.g.: the write buffer is full) and the sender needs to wait until the channel becomes ready again. Returning false also means that the current write was dropped (this MUST be guaranteed to ensure duplication-free delivery).

      Specified by:
      write in interface AssociationHandle
      Parameters:
      payload - The payload to be delivered to the remote endpoint.
      Returns:
      Boolean indicating the availability of the association for subsequent writes.

    • disassociate

      public void disassociate(String reason, LoggingAdapter log)
      Deprecated.
      Description copied from interface: AssociationHandle
      Closes the underlying transport link, if needed. Some transports might not need an explicit teardown (UDP) and some transports may not support it (hardware connections). Remote endpoint of the channel or connection MAY be notified, but this is not guaranteed. The Transport that provides the handle MUST guarantee that disassociate() could be called arbitrarily many times.
      Specified by:
      disassociate in interface AssociationHandle

    • key

      public scala.Tuple2<Address,Address> key()
      Deprecated.
      Key used in pekko.remote.transport.TestTransport.AssociationRegistry to identify associations. Contains an ordered pair of addresses, where the first element of the pair is always the initiator of the association.

    • copy

      public TestAssociationHandle copy(Address localAddress, Address remoteAddress, TestTransport transport, boolean inbound)
      Deprecated.

    • copy$default$1

      public Address copy$default$1()
      Deprecated.

    • copy$default$2

      public Address copy$default$2()
      Deprecated.

    • copy$default$3

      public TestTransport copy$default$3()
      Deprecated.

    • copy$default$4

      public boolean copy$default$4()
      Deprecated.

    • productPrefix

      public String productPrefix()
      Deprecated.
      Specified by:
      productPrefix in interface scala.Product

    • productArity

      public int productArity()
      Deprecated.
      Specified by:
      productArity in interface scala.Product

    • productElement

      public Object productElement(int x$1)
      Deprecated.
      Specified by:
      productElement in interface scala.Product

    • productIterator

      public scala.collection.Iterator<Object> productIterator()
      Deprecated.
      Specified by:
      productIterator in interface scala.Product

    • canEqual

      public boolean canEqual(Object x$1)
      Deprecated.
      Specified by:
      canEqual in interface scala.Equals

    • productElementName

      public String productElementName(int x$1)
      Deprecated.
      Specified by:
      productElementName in interface scala.Product

    • hashCode

      public int hashCode()
      Deprecated.
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Deprecated.
      Overrides:
      toString in class Object

    • equals

      public boolean equals(Object x$1)
      Deprecated.
      Specified by:
      equals in interface scala.Equals
      Overrides:
      equals in class Object