Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @WebMethod
- public void handleSoapRequest() {
- CompletableFuture<JsonObject> responseFuture = new CompletableFuture<>();
- logger.debug("calling fleetmanager REST service- port:"+url.getPort()+" host:"+ url.getHost()+" path:/fleets/"+Config.getFleetId()+"/vehicles");
- if (!check(key)) {
- vertx.createHttpClient().getNow(url.getPort(), url.getHost(), "/groups/"+Config.getGroupId()+"/cars", new Handler<HttpClientResponse>() {
- public void handle(HttpClientResponse httpClientResponse) {
- httpClientResponse.bodyHandler(new Handler<Buffer>() {
- public void handle(Buffer buffer) {
- logger.debug("Response (" + buffer.length() + "): ");
- logger.debug(buffer.getString(0, buffer.length()));
- jsonReply = buffer.toJsonObject();
- responseFuture.complete(jsonReply);
- }
- });
- }});
- }
- return responseFuture.get();
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement