HttpConduitTest.java

import org.apache.cxf.BusFactory;
import org.apache.cxf.jaxrs.client.JAXRSClientFactory;
import org.apache.cxf.transport.http.asyncclient.AsyncHTTPConduitFactory;
import org.junit.Test;

import javax.ws.rs.POST;
import javax.ws.rs.Path;

public class HttpConduitTest {

    @Test
    public void httpConduit() throws Exception {
        BusFactory.getThreadDefaultBus().setProperty(AsyncHTTPConduitFactory.USE_POLICY, AsyncHTTPConduitFactory.UseAsyncPolicy.ALWAYS);

        String invalidService = "https://localhost:12341";

        ExampleResource exampleResource = JAXRSClientFactory.create(invalidService, ExampleResource.class);

        Thread thread = new Thread(() -> {
            try {
                exampleResource.get("some data");
            } catch (Exception e) {
                e.printStackTrace();
            }
        });

        thread.start();
        Thread.sleep(1000);

        BusFactory.getThreadDefaultBus().shutdown(true);

        thread.join();
    }

    @Path("/example")
    public interface ExampleResource {

        @POST
        String get(String data);
    }
}