requireNonNull(changes, "Changes must not be null!");
for (DataTreeModification<Node> change : changes) {
final DataObjectModification<Node> mod = change.getRootNode();
- switch (mod.getModificationType()) {
+ switch (mod.modificationType()) {
case DELETE:
break;
case SUBTREE_MODIFIED:
processNodeModification(change);
break;
default:
- throw new IllegalArgumentException("Unhandled modification type " + mod.getModificationType());
+ throw new IllegalArgumentException("Unhandled modification type " + mod.modificationType());
}
}
}
}
private void processNodeModification(final DataTreeModification<Node> change) {
- final InstanceIdentifier<Node> key = change.getRootPath().getRootIdentifier();
+ final InstanceIdentifier<Node> key = change.getRootPath().path();
final InstanceIdentifier<Node> nodeIdent = key.firstIdentifierOf(Node.class);
String[] nodeIdentity = nodeIdent.firstKeyOf(Node.class).getId().getValue().split(":");
String nodeId = nodeIdentity[1];
when(batchStepJob2.getStepFunction().apply(any())).thenReturn(failedChainOutput);
final List<BatchStepJob> batchChainElements = Lists.newArrayList(batchStepJob1, batchStepJob2);
- final var rpcResultFuture = processFlatBatch.executeBatchPlan(batchChainElements);
+ final var rpcResultFuture = ProcessFlatBatchImpl.executeBatchPlan(batchChainElements);
assertTrue(rpcResultFuture.isDone());
final var rpcResult = rpcResultFuture.get();
.success(new AddFlowsBatchOutputBuilder().build())
.buildFuture());
- final var rpcResultFuture = processFlatBatch.executeBatchPlan(batchChain);
+ final var rpcResultFuture = ProcessFlatBatchImpl.executeBatchPlan(batchChain);
assertTrue(rpcResultFuture.isDone());
final var rpcResult = rpcResultFuture.get();
assertTrue(rpcResult.isSuccessful());
.withError(ErrorType.APPLICATION, "ut-addFlowBatchError")
.buildFuture());
- final var rpcResultFuture = processFlatBatch.executeBatchPlan(batchChain);
+ final var rpcResultFuture = ProcessFlatBatchImpl.executeBatchPlan(batchChain);
assertTrue(rpcResultFuture.isDone());
final var rpcResult = rpcResultFuture.get();
assertFalse(rpcResult.isSuccessful());