- InstanceIdentifier<Link> linkInstanceId = InstanceIdentifier.builder(NetworkTopology.class)
- .child(Topology.class, topology).child(Link.class, link.getKey()).build();
- return linkInstanceId;
- }
-
- /**
- * @param txId transaction identificator
- * @param future transaction result
- */
- private static void listenOnTransactionState(final Object txId, Future<RpcResult<TransactionStatus>> future) {
- Futures.addCallback(JdkFutureAdapters.listenInPoolThread(future),new FutureCallback<RpcResult<TransactionStatus>>() {
-
- @Override
- public void onFailure(Throwable t) {
- LOG.error("Topology export failed for Tx:{}", txId, t);
-
- }
-
- @Override
- public void onSuccess(RpcResult<TransactionStatus> result) {
- if(!result.isSuccessful()) {
- LOG.error("Topology export failed for Tx:{}", txId);
- }
- }
- });