(chore) new async test

Author: trajano

ms-common-impl/src/test/java/net/trajano/ms/sample/Hello.java

@@ -1,15 +1,23 @@
 package net.trajano.ms.sample;
 
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Future;
+
 import javax.annotation.security.PermitAll;
 import javax.ws.rs.GET;
 import javax.ws.rs.Path;
 import javax.ws.rs.Produces;
+import javax.ws.rs.client.Client;
+import javax.ws.rs.container.AsyncResponse;
+import javax.ws.rs.container.Suspended;
 import javax.ws.rs.core.Context;
 import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
 
 import org.springframework.beans.factory.annotation.Autowired;
 
 import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
 import io.vertx.ext.web.RoutingContext;
 
 @Api
@@ -18,12 +26,35 @@ public class Hello {
 
     private int count;
 
+    @Context
+    private Client jaxrsClient;
+
     @Autowired
     SomeRequestScope req;
 
     @Autowired
     ISomeAppScope scope;
 
+    @ApiOperation(value = "displays openid config of google async",
+        hidden = true)
+    @GET
+    @Produces(MediaType.APPLICATION_JSON)
+    @Path("/async")
+    @PermitAll
+    public void async(@Suspended final AsyncResponse asyncResponse) throws InterruptedException,
+        ExecutionException {
+
+        final Future<Response> futureResponseFromClient = jaxrsClient.target("https://accounts.google.com/.well-known/openid-configuration").request().header(javax.ws.rs.core.HttpHeaders.USER_AGENT, "curl/7.55.1").async().get();
+
+        final Response responseFromClient = futureResponseFromClient.get();
+        try {
+            final String object = responseFromClient.readEntity(String.class);
+            asyncResponse.resume(object);
+        } finally {
+            responseFromClient.close();
+        }
+    }
+
     @GET
     @Path("/cough")
     public String cough() {

ms-common-impl/src/test/java/net/trajano/ms/vertx/test/SpringJaxrsHandlerTest.java

@@ -59,6 +59,16 @@ public static void setApplication() {
     @Autowired
     private HttpClientOptions httpClientOptions;
 
+    @Test
+    public void testAsync() {
+
+        assertNotNull(engine);
+        final Response response = ClientBuilder.newClient().target(baseUri).path("/api/hello/async").request().get();
+        assertEquals(200, response.getStatus());
+        assertTrue(response.readEntity(String.class).startsWith("{"));
+
+    }
+
     @Test
     public void testEngine() {