eventCounters.put(type, new AtomicLong(0));
            eventTimings.put(type, new AtomicLong(0));
        }

        // Start async logging processor
        startAsyncProcessor();

        // Register shutdown hook
        Runtime.getRuntime().addShutdownHook(new Thread(this::shutdown));
    }

    private void startAsyncProcessor() {
        logExecutor.submit(() -> {
            while (!shutdown) {

						this._nextCallbackTimeoutID++;
						this._scheduledTimeouts.set(id, setTimeout(
							() => {
								this._resume();
								while (this._scheduledTimeouts.has(id)) {
									// for some reason Go failed to register the timeout event, log and try again
									// (temporary workaround for https://github.com/golang/go/issues/28975)
									console.warn("scheduleTimeoutEvent: missed timeout event");
									this._resume();
								}

        ALLOW_DATA_ATTR: false,
        ALLOWED_URI_REGEXP: /^https?:\/\//i
    };
    function initMarkdownSanitizer() {
        if (markdownDomPurifyInitialized || typeof DOMPurify === 'undefined') return;
        // Register hook once: add rel="nofollow" to links, restrict class to code/pre/span/div
        // (matches server-side requireRelNofollowOnLinks and allowAttributes("class").onElements(...))

    /**
     * Default constructor.
     */
    public ChatApiManager() {
        // Default constructor
    }

    /**
     * Registers this API manager with the WebApiManagerFactory.
     */
    @PostConstruct
    public void register() {
        if (logger.isInfoEnabled()) {
            logger.info("Registering ChatApiManager");
        }
        ComponentUtil.getWebApiManagerFactory().add(this);

				"application/mbms-msk+xml",
				"application/mbms-msk-response+xml",
				"application/mbms-protection-description+xml",
				"application/mbms-reception-report+xml",
				"application/mbms-register+xml",
				"application/mbms-register-response+xml",
				"application/mbms-user-service-description+xml",
				"application/mbox",
				"application/media_control+xml",
				"application/mediaservercontrol+xml",
				"application/mikey",

  }

  public void testNoExceptionsThrown() throws IOException {
    Closer closer = new Closer(suppressor);

    TestCloseable c1 = closer.register(TestCloseable.normal());
    TestCloseable c2 = closer.register(TestCloseable.normal());
    TestCloseable c3 = closer.register(TestCloseable.normal());

    assertFalse(c1.isClosed());
    assertFalse(c2.isClosed());
    assertFalse(c3.isClosed());

    closer.close();

    // objects indefinitely.
    private void drainQueue() {
      Reference<? extends L> ref;
      while ((ref = queue.poll()) != null) {
        // We only ever register ArrayReferences with the queue so this is always safe.
        ArrayReference<? extends L> arrayRef = (ArrayReference<? extends L>) ref;
        // Try to clear out the array slot, n.b. if we fail that is fine, in either case the

    group = "Versioning"
}

tasks.register<UpdateReleasedVersions>("updateReleasedVersions") {
    currentReleasedVersion = ReleasedVersion(
        project.findProperty("currentReleasedVersion").toString(),
        project.findProperty("currentReleasedVersionBuildTimestamp").toString()
    )
}

val updateAgpVersions = tasks.register<UpdateAgpVersions>("updateAgpVersions") {

            @Override
            public void storeSearchLog() {
                // Successful execution - no exception thrown
            }
        };
        ComponentUtil.register(mockSearchLogHelper, "searchLogHelper");

        // Execute the job
        String result = aggregateLogJob.execute();

        // Verify result is empty string on success
        assertNotNull(result);

    assertEquals(0, registry.getSubscribersForTesting(String.class).size());

    registry.register(new StringSubscriber());
    assertEquals(1, registry.getSubscribersForTesting(String.class).size());

    registry.register(new StringSubscriber());
    assertEquals(2, registry.getSubscribersForTesting(String.class).size());

    registry.register(new ObjectSubscriber());
    assertEquals(2, registry.getSubscribersForTesting(String.class).size());