+ outboundQueue.commitEntry(reservedXid, MultipartRequestInputFactory.makeMultipartRequestInput(xid.getValue(), version, type), new FutureCallback<OfHeader>() {
+ @Override
+ public void onSuccess(final OfHeader ofHeader) {
+ LOG.info("Static node {} info: {} collected", type);
+ }
+
+
+ @Override
+ public void onFailure(final Throwable t) {
+ LOG.info("Failed to retrieve static node {} info: {}", type, t.getMessage());
+ }
+ });
+
+ Futures.addCallback(requestContextFuture, new FutureCallback<RpcResult<List<MultipartReply>>>() {