helper.publishEvent("config_updated", "node2@host2", "web_config");

        assertNotNull(capturedBody.get());
        final Map<String, Object> body = coordinatorHelper.parseJson(capturedBody.get());
        assertEquals("event", body.get("type"));
        assertEquals("config_updated", body.get("name"));
        assertEquals("node1@host1", body.get("instanceId"));
        assertEquals("node2@host2", body.get("targetInstanceId"));

        assertFalse(messages1.isEmpty());

        final FessMessages messages2 = new FessMessages();
        messages2.addErrorsOperationAlreadyRunning("prop", "node1@host2");
        assertFalse(messages2.isEmpty());
    }

    // ===================================================================================