Class representing an acknowledgement with selective negative acknowledgements.
Represents the highest sequence number received.
Set of sequence numbers between the last delivered one and cumulativeAck that has been not yet received.
Implements an immutable receive buffer that buffers incoming messages until they can be safely delivered.
Sequence number of the last message that has been delivered.
The highest sequence number received so far.
Buffer of messages that are waiting for delivery
Implements an immutable resend buffer that buffers messages until they have been acknowledged.
Maximum number of messages the buffer is willing to accept. If reached akka.remote.ResendBufferCapacityReachedException is thrown.
Sequence of messages that has not yet been acknowledged.
Sequence of messages that has been explicitly negative acknowledged.
The maximum sequence number that has been stored in this buffer. Messages having lower sequence number will be not stored but rejected with java.lang.IllegalArgumentException
Implementation of failure detector using an absolute timeout of missing heartbeats to trigger unavailability.
A lock-less thread-safe implementation of akka.remote.FailureDetectorRegistry.
A failure detector must be a thread-safe mutable construct that registers heartbeat events of a resource and is able to decide the availability of that monitored resource.
Interface for a registry of Akka failure detectors.
The type of the key that identifies a resource to be monitored by a failure detector
Implementation of 'The Phi Accrual Failure Detector' by Hayashibara et al.
RemoteTransportException represents a general failure within a RemoteTransport, such as inability to start, wrong configuration etc.
RemoteTransportException without stack trace.
Implements a 64 bit sequence number with proper wrap-around ordering.
Extension that holds a uid that is assigned as a random