| | |
| | | try { |
| | | CompletableFuture<Data> feature = (CompletableFuture<Data>) features.get(comId); |
| | | System.out.println("receive result ID:" + comId); |
| | | Data resultData = feature.get(30, TimeUnit.SECONDS); |
| | | Data resultData = feature.get(180, TimeUnit.SECONDS); |
| | | features.remove(comId); |
| | | Long commandId = Long.parseLong(resultData.getCommandId()); |
| | | if(commandId.equals(comId)) { |
| | |
| | | e.printStackTrace(); |
| | | return BaseResponseUtils.buildFail(CommandResultCode.GET_RESULT_ERROR.getMessage()); |
| | | } catch (TimeoutException e) { |
| | | return BaseResponseUtils.buildFail(CommandResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage()); |
| | | return BaseResponseUtils.buildSuccess(CommandResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage()); |
| | | } |
| | | } |
| | | |