final AtomicReference<String> capturedBody = new AtomicReference<>();
        final CoordinatorHelper helper = createCapturingHelper("node1@host1", null, capturedBody, createMockResponse(201, "{}"));

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

        assertNotNull(capturedBody.get());
        final Map<String, Object> body = coordinatorHelper.parseJson(capturedBody.get());