Package org.apache.pekko.remote

Class AckedReceiveBuffer<T extends HasSequenceNumber>

java.lang.Object
org.apache.pekko.remote.AckedReceiveBuffer<T>
All Implemented Interfaces:
Serializable, scala.Equals, scala.Product
public final class AckedReceiveBuffer<T extends HasSequenceNumber> extends Object implements scala.Product, Serializable
Deprecated.
Classic remoting is deprecated, use Artery. Since Akka 2.6.0.
Implements an immutable receive buffer that buffers incoming messages until they can be safely delivered. This buffer works together with a pekko.remote.AckedSendBuffer on the sender() side.

param: lastDelivered Sequence number of the last message that has been delivered. param: cumulativeAck The highest sequence number received so far. param: buf Buffer of messages that are waiting for delivery

See Also:

  • Constructor Details

    • AckedReceiveBuffer

      public AckedReceiveBuffer(SeqNo lastDelivered, SeqNo cumulativeAck, scala.collection.immutable.SortedSet<T> buf, scala.math.Ordering<T> seqOrdering)
      Deprecated.

  • Method Details

    • $lessinit$greater$default$1

      public static <T extends HasSequenceNumber> SeqNo $lessinit$greater$default$1()
      Deprecated.

    • $lessinit$greater$default$2

      public static <T extends HasSequenceNumber> SeqNo $lessinit$greater$default$2()
      Deprecated.

    • $lessinit$greater$default$3

      public static <T extends HasSequenceNumber> scala.collection.immutable.TreeSet<T> $lessinit$greater$default$3()
      Deprecated.

    • apply

      public static <T extends HasSequenceNumber> AckedReceiveBuffer<T> apply(SeqNo lastDelivered, SeqNo cumulativeAck, scala.collection.immutable.SortedSet<T> buf, scala.math.Ordering<T> seqOrdering)
      Deprecated.

    • apply$default$1

      public static <T extends HasSequenceNumber> SeqNo apply$default$1()
      Deprecated.

    • apply$default$2

      public static <T extends HasSequenceNumber> SeqNo apply$default$2()
      Deprecated.

    • apply$default$3

      public static <T extends HasSequenceNumber> scala.collection.immutable.TreeSet<T> apply$default$3()
      Deprecated.

    • unapply

      public static <T extends HasSequenceNumber> scala.Option<scala.Tuple3<SeqNo,SeqNo,scala.collection.immutable.SortedSet<T>>> unapply(AckedReceiveBuffer<T> x$0)
      Deprecated.

    • lastDelivered

      public SeqNo lastDelivered()
      Deprecated.

    • cumulativeAck

      public SeqNo cumulativeAck()
      Deprecated.

    • buf

      public scala.collection.immutable.SortedSet<T> buf()
      Deprecated.

    • seqOrdering

      public scala.math.Ordering<T> seqOrdering()
      Deprecated.

    • receive

      public AckedReceiveBuffer<T> receive(T arrivedMsg)
      Deprecated.
      Puts a sequenced message in the receive buffer returning a new buffer.
      Parameters:
      arrivedMsg - message to be put into the buffer.
      Returns:
      The updated buffer containing the message.

    • extractDeliverable

      public scala.Tuple3<AckedReceiveBuffer<T>,scala.collection.immutable.Seq<T>,Ack> extractDeliverable()
      Deprecated.
      Extract all messages that could be safely delivered, an updated ack to be sent to the sender(), and an updated buffer that has the messages removed that can be delivered.
      Returns:
      Triplet of the updated buffer, messages that can be delivered and the updated acknowledgement.

    • mergeFrom

      public AckedReceiveBuffer<T> mergeFrom(AckedReceiveBuffer<T> that)
      Deprecated.
      Merges two receive buffers. Merging preserves sequencing of messages, and drops all messages that has been safely acknowledged by any of the participating buffers. Also updates the expected sequence numbers.
      Parameters:
      that - The receive buffer to merge with
      Returns:
      The merged receive buffer.

    • toString

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

    • copy

      public <T extends HasSequenceNumber> AckedReceiveBuffer<T> copy(SeqNo lastDelivered, SeqNo cumulativeAck, scala.collection.immutable.SortedSet<T> buf, scala.math.Ordering<T> seqOrdering)
      Deprecated.

    • copy$default$1

      public <T extends HasSequenceNumber> SeqNo copy$default$1()
      Deprecated.

    • copy$default$2

      public <T extends HasSequenceNumber> SeqNo copy$default$2()
      Deprecated.

    • copy$default$3

      public <T extends HasSequenceNumber> scala.collection.immutable.SortedSet<T> copy$default$3()
      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

    • equals

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