Thread.sleep(10);
}
} catch (InterruptedException e1) {
- logger.warn("DiscoveryTransmit interupted", e1.getMessage());
+ logger.trace("DiscoveryTransmit interupted", e1.getMessage());
if (shuttingDown) {
return;
}
if (!src.getType().equals(NodeConnector.NodeConnectorIDType.PRODUCTION)) {
if (type == UpdateType.ADDED) {
edgeMap.put(dst, edge);
- } else {
+ } else if (type == UpdateType.REMOVED) {
edgeMap.remove(dst);
}
} else {
*/
if (type == UpdateType.ADDED) {
prodMap.put(dst, edge);
- } else {
+ } else if (type == UpdateType.REMOVED) {
prodMap.remove(dst);
}
}