- Futures.addCallback(wTx.submit(), new FutureCallback<Void>() {
-
- @Override
- public void onSuccess(Void result) {
- DataTreeIdentifier<Topology> topoIdentifier =
- new DataTreeIdentifier<>(LogicalDatastoreType.OPERATIONAL, topologyIid);
- new ListenableFutureSetter<>(dataProvder, topoFuture, topoIdentifier,
- ModificationType.WRITE);
- }
-
- @Override
- public void onFailure(Throwable t) {
- LOG.warn("Request create topology for VBD was not stored to CONF DS. {}", topologyIid, t);
- topoFuture.setException(new Exception("Cannot send request to VBD."));
- }});
- } else {
- topoFuture.set(null);