Package org.apache.pekko.remote

Class AckedSendBuffer<T extends HasSequenceNumber>

java.lang.Object
org.apache.pekko.remote.AckedSendBuffer<T>
All Implemented Interfaces:
Serializable, scala.Equals, scala.Product
public final class AckedSendBuffer<T extends HasSequenceNumber> extends Object implements scala.Product, Serializable
Deprecated.
Classic remoting is deprecated, use Artery. Since Akka 2.6.0.
Implements an immutable resend buffer that buffers messages until they have been acknowledged. Properly removes messages when an ack is received. This buffer works together with pekko.remote.AckedReceiveBuffer on the receiving end.

param: capacity Maximum number of messages the buffer is willing to accept. If reached pekko.remote.ResendBufferCapacityReachedException is thrown. param: nonAcked Sequence of messages that has not yet been acknowledged. param: nacked Sequence of messages that has been explicitly negative acknowledged. param: maxSeq The maximum sequence number that has been stored in this buffer. Messages having lower sequence number will be not stored but rejected with IllegalArgumentException

See Also:

  • Constructor Details

    • AckedSendBuffer

      public AckedSendBuffer(int capacity, scala.collection.immutable.IndexedSeq<T> nonAcked, scala.collection.immutable.IndexedSeq<T> nacked, SeqNo maxSeq)
      Deprecated.

  • Method Details

    • $lessinit$greater$default$2

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

    • $lessinit$greater$default$3

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

    • $lessinit$greater$default$4

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

    • apply

      public static <T extends HasSequenceNumber> AckedSendBuffer<T> apply(int capacity, scala.collection.immutable.IndexedSeq<T> nonAcked, scala.collection.immutable.IndexedSeq<T> nacked, SeqNo maxSeq)
      Deprecated.

    • apply$default$2

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

    • apply$default$3

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

    • apply$default$4

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

    • unapply

      public static <T extends HasSequenceNumber> scala.Option<scala.Tuple4<Object,scala.collection.immutable.IndexedSeq<T>,scala.collection.immutable.IndexedSeq<T>,SeqNo>> unapply(AckedSendBuffer<T> x$0)
      Deprecated.

    • capacity

      public int capacity()
      Deprecated.

    • nonAcked

      public scala.collection.immutable.IndexedSeq<T> nonAcked()
      Deprecated.

    • nacked

      public scala.collection.immutable.IndexedSeq<T> nacked()
      Deprecated.

    • maxSeq

      public SeqNo maxSeq()
      Deprecated.

    • acknowledge

      public AckedSendBuffer<T> acknowledge(Ack ack)
      Deprecated.
      Processes an incoming acknowledgement and returns a new buffer with only unacknowledged elements remaining.
      Parameters:
      ack - The received acknowledgement
      Returns:
      An updated buffer containing the remaining unacknowledged messages

    • buffer

      public AckedSendBuffer<T> buffer(T msg)
      Deprecated.
      Puts a new message in the buffer. Throws IllegalArgumentException if an out-of-sequence message is attempted to be stored.
      Parameters:
      msg - The message to be stored for possible future retransmission.
      Returns:
      The updated buffer

    • toString

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

    • copy

      public <T extends HasSequenceNumber> AckedSendBuffer<T> copy(int capacity, scala.collection.immutable.IndexedSeq<T> nonAcked, scala.collection.immutable.IndexedSeq<T> nacked, SeqNo maxSeq)
      Deprecated.

    • copy$default$1

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

    • copy$default$2

      public <T extends HasSequenceNumber> scala.collection.immutable.IndexedSeq<T> copy$default$2()
      Deprecated.

    • copy$default$3

      public <T extends HasSequenceNumber> scala.collection.immutable.IndexedSeq<T> copy$default$3()
      Deprecated.

    • copy$default$4

      public <T extends HasSequenceNumber> SeqNo 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

    • equals

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