@Test
    public void test_process_withJobLogId_setsIdOnJobLog() {
        final ScheduledJob scheduledJob = createTestScheduledJob("proc-1", true);
        final AtomicReference<JobLog> storedJobLog = new AtomicReference<>();

        registerComponents(scheduledJob, storedJobLog);

        // Create runtime with JOB_LOG_ID parameter
        final Map<String, Object> params = new HashMap<>();

        final AtomicBoolean storeCalled = new AtomicBoolean(false);
        final AtomicReference<DataConfig> capturedConfig = new AtomicReference<>();
        final AtomicReference<IndexUpdateCallback> capturedCallback = new AtomicReference<>();
        final AtomicReference<DataStoreParams> capturedParams = new AtomicReference<>();

        dataStore = new DataStore() {
            @Override

    assertThat(sepLoader).isSameInstanceAs(sepStopwatchC.getClassLoader());
    AtomicReference<Object> sepStopwatchA =
        new AtomicReference<Object>(sepStopwatchC.getMethod("createUnstarted").invoke(null));
    AtomicReference<WeakReference<?>> sepStopwatchRef =
        new AtomicReference<WeakReference<?>>(
            (WeakReference<?>) sepFwrCons.newInstance(sepStopwatchA.get(), sepFrqA.get()));

    @Test
    public void test_OnConnect_ReceivesBothRequestAndConnection() throws Exception {
        // ## Arrange ##
        AtomicReference<CurlRequest> receivedRequest = new AtomicReference<>();
        AtomicReference<HttpURLConnection> receivedConnection = new AtomicReference<>();
        CurlRequest req = new OpenOverrideCurlRequest(Curl.Method.GET, "http://dummy",

    assertThat(sepLoader).isSameInstanceAs(sepStopwatchC.getClassLoader());
    AtomicReference<Object> sepStopwatchA =
        new AtomicReference<Object>(sepStopwatchC.getMethod("createUnstarted").invoke(null));
    AtomicReference<WeakReference<?>> sepStopwatchRef =
        new AtomicReference<WeakReference<?>>(
            (WeakReference<?>) sepFwrCons.newInstance(sepStopwatchA.get(), sepFrqA.get()));

        assertTrue(secondCalled.get());
    }

    @Test
    public void test_dispatchEvent_eventData() {
        final AtomicReference<String> receivedData = new AtomicReference<>();
        final AtomicReference<String> receivedInstanceId = new AtomicReference<>();
        coordinatorHelper.addEventHandler("config_updated", event -> {
            receivedData.set(event.data);

   * That is, even if exactly the same method works from inside the common.eventbus package tests,
   * it can fail here.
   */
  public void testAnonymous() {
    AtomicReference<String> holder = new AtomicReference<>();
    AtomicInteger deliveries = new AtomicInteger();
    EventBus bus = new EventBus();
    bus.register(
        new Object() {
          @Subscribe
          public void accept(String str) {

            @Override
            public void close() {
            }
        };

        CountDownLatch latch = new CountDownLatch(1);
        AtomicReference<SuggestIndexResponse> responseRef = new AtomicReference<>();
        AtomicReference<Throwable> errorRef = new AtomicReference<>();

        Deferred<SuggestIndexResponse>.Promise promise = suggester.indexer().indexFromQueryLog(emptyReader, 10, 0);

        final Deferred<SuggestResponse> deferred = new Deferred<>();
        final AtomicInteger callbackCount = new AtomicInteger(0);
        final AtomicReference<String> receivedIndex = new AtomicReference<>();

        deferred.promise().then(response -> {
            callbackCount.incrementAndGet();
            receivedIndex.set(response.getIndex());
        });

    AtomicBoolean actualIsOccupied = new AtomicBoolean();
    AtomicBoolean actualIsOccupiedByCurrentThread = new AtomicBoolean();
    AtomicInteger actualOccupiedDepth = new AtomicInteger();
    AtomicReference<Throwable> thrown = new AtomicReference<>();
    joinUninterruptibly(
        startThread(
            () -> {
              try {
                actualIsOccupied.set(monitor.isOccupied());