}
private Channel testMonitoringStation(final String remoteRouterIpAddr) throws InterruptedException {
final Channel channel = connectTestClient(remoteRouterIpAddr, this.msgRegistry);
final RouterId routerId = getRouterId(remoteRouterIpAddr);
try {
<BUG>readData(MONITOR_IID, monitor -> {
</BUG>
assertFalse(monitor.getRouter().isEmpty());
Router router = null;
for (final Router r : monitor.getRouter()) {

}
private void waitWriteAndFlushSuccess(final ChannelFuture channelFuture) throws InterruptedException {
waitFutureSuccess(channelFuture);
}
private Channel testMonitoringStation(final String remoteRouterIpAddr) throws InterruptedException {
final Channel channel = connectTestClient(remoteRouterIpAddr, this.msgRegistry);
final RouterId routerId = getRouterId(remoteRouterIpAddr);
try {
readData(getDataBroker(), MONITOR_IID, monitor -> {
assertFalse(monitor.getRouter().isEmpty());
Router router = null;
for (final Router r : monitor.getRouter()) {
