+
+ override sollicitRefresh() {
+ topologyDiscovery.solicitRefresh
+ }
+
+ override onLinkDiscovered(LinkDiscovered notification) {
+ val update = new TopoEdgeUpdate(notification.toADEdge,Collections.emptySet(),UpdateType.ADDED);
+ discoveryPublisher.notifyEdge(notification.toADEdge,UpdateType.ADDED,Collections.emptySet());
+ topologyPublisher.edgeUpdate(Collections.singletonList(update))
+ }
+
+ override onLinkOverutilized(LinkOverutilized notification) {
+ topologyPublisher.edgeOverUtilized(notification.toADEdge)
+ }
+
+ override onLinkRemoved(LinkRemoved notification) {
+ val update = new TopoEdgeUpdate(notification.toADEdge,Collections.emptySet(),UpdateType.REMOVED);
+ topologyPublisher.edgeUpdate(Collections.singletonList(update))
+ }
+
+ override onLinkUtilizationNormal(LinkUtilizationNormal notification) {
+ topologyPublisher.edgeUtilBackToNormal(notification.toADEdge)
+ }
+
+
+ def Edge toADEdge(Link link) {
+ new Edge(link.source.toADNodeConnector,link.destination.toADNodeConnector)
+ }
+