}
    }

    @Test
    public void testBackpressureControl() throws Exception {
        // Create circuit breaker with backpressure enabled
        SmbCircuitBreaker backpressureCircuitBreaker = new SmbCircuitBreaker("backpressure-test", 5, 2, 1000, 3, false, true, 2);

        try {
            CountDownLatch startLatch = new CountDownLatch(1);

 * thrown and no [WebSocketListener.onFailure] callback is triggered, so callers should always check
 * the return value of `send()`.
 *
 * Use [queueSize] to monitor backpressure before sending. For large payloads, consider breaking
 * them into smaller messages or using HTTP requests instead.
 */
interface WebSocket {
  /** Returns the original request that initiated this web socket. */

        // Backpressure control
        if (backpressureEnabled && requestSemaphore != null) {
            if (!requestSemaphore.tryAcquire()) {
                totalBackpressureRejections.incrementAndGet();
                throw new CIFSException("Circuit breaker '" + name + "' rejected request due to backpressure");
            }
        }

 *       doesn't offer a way to wait for multiple producers to all report that they're "ready," nor
 *       does it offer a way to batch multiple events from a single producer together.
 *   <li>It doesn't support backpressure and other features needed for resilience.
 *   <li>It doesn't provide much control of threading.
 *   <li>It doesn't offer much monitoring.
 *   <li>It doesn't propagate exceptions, so apps don't have a way to react to them.