- final Map<String, Request> identifierRequests = new HashMap<String, Request>();
- nodeRequests.put(node, identifierRequests);
- HighLevelCallback<RequestListResult> requestListCallback = highLevelClient.getRequests();
- requestListCallback.addHighLevelCallbackListener(new HighLevelCallbackListener<RequestListResult>() {
-
- @SuppressWarnings("synthetic-access")
- public void gotResult(HighLevelCallback<RequestListResult> highLevelCallback) {
- RequestListResult requestListResult;
- try {
- requestListResult = highLevelCallback.getResult();
- } catch (InterruptedException e) {
- logger.log(Level.SEVERE, "getResult() blocked and was interrupted");
- return;
- }
- for (RequestResult requestResult: requestListResult) {
- Request request = new Request(node, requestResult.getIdentifier());
- identifierRequests.put(requestResult.getIdentifier(), request);
- /* TODO - fill request */
- fireRequestAdded(request);
- }
- }
- });