Class BackpressureException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

com.loomcache.common.exception.LoomException

com.loomcache.common.exception.BackpressureException

All Implemented Interfaces:

Serializable

public final class BackpressureException
extends LoomException

Thrown when a peer is backpressured (cannot accept messages).

This exception indicates that a remote peer is overwhelmed and cannot accept additional messages at this time. The outbound queue to the peer has reached or exceeded the configured high watermark threshold.

This is a transient error: clients may retry after some delay or implement exponential backoff. The backpressure condition will be cleared once the peer's queue drains back to the low watermark.

Since:

1.0

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
BackpressureException(String peerId)	Creates a new BackpressureException for a peer.
BackpressureException(String message, String peerId)	Creates a new BackpressureException with a custom message.

Method Summary

Methods inherited from class Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

BackpressureException

public BackpressureException(String peerId)

Creates a new BackpressureException for a peer.

Parameters:

peerId - the identifier of the backpressured peer (must not be null)

BackpressureException

public BackpressureException(String message,
 String peerId)

Creates a new BackpressureException with a custom message.

Parameters:

message - the error message (must not be null)

peerId - the identifier of the backpressured peer (must not be null)