- Futures.addCallback(deviceFeaturesFuture, new FutureCallback<List<RpcResult<List<MultipartReply>>>>() {
- @Override
- public void onSuccess(final List<RpcResult<List<MultipartReply>>> result) {
- LOG.debug("All init data for node {} is in submited.", deviceInfo.getNodeId());
- returnFuture.set(null);
- }
-
- @Override
- public void onFailure(final Throwable t) {
- // FIXME : remove session
- LOG.trace("Device capabilities gathering future failed.");
- LOG.trace("more info in exploration failure..", t);
- LOG.debug("All init data for node {} was not submited correctly - connection has to go down.", deviceInfo.getNodeId());
- returnFuture.setException(t);
- }
- });
- return returnFuture;