Optional.of(MsgBuilderUtil.createSrp(srpId)), MsgBuilderUtil.createPath(req.getEro().getSubobject()));
this.listener.onMessage(this.session, pcRpt);
readDataOperational(getDataBroker(), TOPO_IID, topology -> {
- assertEquals(1, topology.getNode().size());
+ assertEquals(1, topology.nonnullNode().size());
return topology;
});
}
Optional.of(MsgBuilderUtil.createSrp(srpId)), MsgBuilderUtil.createPath(req.getEro().getSubobject()));
this.listener.onMessage(this.session, pcRpt);
readDataOperational(getDataBroker(), TOPO_IID, topology -> {
- assertEquals(1, topology.getNode().size());
+ assertEquals(1, topology.nonnullNode().size());
return topology;
});
Optional.of(MsgBuilderUtil.createSrp(srpId)), MsgBuilderUtil.createPath(req.getEro().getSubobject()));
this.listener.onMessage(this.session, pcRpt);
readDataOperational(getDataBroker(), TOPO_IID, topology -> {
- assertEquals(1, topology.getNode().size());
+ assertEquals(1, topology.nonnullNode().size());
return topology;
});
this.listener.onSessionUp(this.session);
this.listener.onMessage(this.session, rptmsg);
readDataOperational(getDataBroker(), TOPO_IID, node -> {
- assertFalse(node.getNode().isEmpty());
+ assertFalse(node.nonnullNode().isEmpty());
return node;
});
}