}

            ILoggerFactory iLoggerFactory = LoggerFactory.getILoggerFactory();

            if (iLoggerFactory instanceof org.apache.maven.logging.api.LogLevelRecorder recorder
                    && recorder.hasReachedMaxLevel()) {
                event.getSession()
                        .getResult()
                        .addException(

	if err != nil {
		return err
	}
	key := eventData.S3.Bucket.Name + "/" + objectName

	data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}})
	if err != nil {
		return err
	}

	return target.producer.Publish(target.args.Topic, data)
}

// SendFromStore - reads an event from store and sends it to NSQ.

    }

    @Deprecated
    public BsGroupCQ addOrderBy_Id_Asc() {
        regOBA("_id");
        return this;
    }

    @Deprecated
    public BsGroupCQ addOrderBy_Id_Desc() {
        regOBD("_id");
        return this;
    }

    public void setGidNumber_Equal(Long gidNumber) {
        setGidNumber_Term(gidNumber, null);
    }

    class SubscribesToPrimitive {
      @Subscribe
      public void toInt(int i) {}
    }
    assertThrows(IllegalArgumentException.class, () -> bus.register(new SubscribesToPrimitive()));
  }

  /** Records thrown exception information. */
  private static final class RecordingSubscriberExceptionHandler
      implements SubscriberExceptionHandler {
    private SubscriberExceptionContext context;
    private Throwable exception;

    class SubscribesToPrimitive {
      @Subscribe
      public void toInt(int i) {}
    }
    assertThrows(IllegalArgumentException.class, () -> bus.register(new SubscribesToPrimitive()));
  }

  /** Records thrown exception information. */
  private static final class RecordingSubscriberExceptionHandler
      implements SubscriberExceptionHandler {
    private SubscriberExceptionContext context;
    private Throwable exception;

        @Override
        int readBytesWireFormat(byte[] buffer, int bufferIndex) {
            readBytesCalls++;
            return 20;
        }
    }

    /**
     * SigningDigest spy that records whether sign() was invoked.
     */
    static class TestSigningDigest extends SigningDigest {
        boolean called;
        int lastLength;

        TestSigningDigest() throws SmbException {

 * buckets for the key and the value. This allows reuse in {@link RegularImmutableMap} and {@link
 * RegularImmutableBiMap}, which don't have to recopy the entries created by their {@code Builder}
 * implementations.
 *
 * <p>This base implementation has no key or value pointers, so instances of ImmutableMapEntry (but

```Python
from fastapi import FastAPI
from unicorn import UnicornMiddleware

app = FastAPI()

app.add_middleware(UnicornMiddleware, some_config="rainbow")
```

`app.add_middleware()` reçoit une classe de middleware en premier argument, ainsi que tout argument supplémentaire à transmettre au middleware.

## Utiliser les middlewares intégrés { #integrated-middlewares }

Pour les configurer, passez l'argument `swagger_ui_parameters` lors de la création de l'objet d'application `FastAPI()` ou à la fonction `get_swagger_ui_html()`.

`swagger_ui_parameters` reçoit un dictionnaire avec les configurations passées directement à Swagger UI.

FastAPI convertit les configurations en **JSON** pour les rendre compatibles avec JavaScript, car c'est ce dont Swagger UI a besoin.

        }
    }

    // --- Timeout application tests (using open(URL) override to test production connect() path) ---

    /**
     * Mock HttpURLConnection that records timeout values.
     */
    class TimeoutRecordingMockHttpURLConnection extends HttpURLConnection {
        int recordedConnectTimeout = -999;
        int recordedReadTimeout = -999;