import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
import org.opendaylight.openflowplugin.applications.southboundcli.alarm.AlarmAgent;
import org.opendaylight.openflowplugin.applications.southboundcli.util.OFNode;
import org.opendaylight.openflowplugin.applications.southboundcli.util.ShellUtil;
ReadWriteTransaction tx = broker.newReadWriteTransaction();
Optional<ReconcileCounter> optional = readReconcileCounterFromDS(tx, instanceIdentifier, nodeId);
ReconcileCounterBuilder counterBuilder = new ReconcileCounterBuilder()
- .setKey(new ReconcileCounterKey(nodeId)).setNodeId(nodeId)
+ .withKey(new ReconcileCounterKey(nodeId)).setNodeId(nodeId)
.setLastRequestTime(LocalDateTime.now().toString());
if (reconcileState) {
counterBuilder.setSuccessCount(startCount);
}
try {
tx.merge(LogicalDatastoreType.OPERATIONAL, instanceIdentifier, counterBuilder.build(), true);
- tx.submit().checkedGet();
- } catch (TransactionCommitFailedException e) {
+ tx.submit().get();
+ } catch (InterruptedException | ExecutionException e) {
LOG.error("Exception while submitting counter {}", nodeId, e);
}
}