diff --git a/src/main/java/net/floodlightcontroller/devicemanager/internal/DeviceManagerImpl.java b/src/main/java/net/floodlightcontroller/devicemanager/internal/DeviceManagerImpl.java index 6c57062c395afeeced2a9166428fa38b27a16900..2602dfdb7eb62a2311e1f2e21e0de4898c7c5e2a 100755 --- a/src/main/java/net/floodlightcontroller/devicemanager/internal/DeviceManagerImpl.java +++ b/src/main/java/net/floodlightcontroller/devicemanager/internal/DeviceManagerImpl.java @@ -638,6 +638,7 @@ public class DeviceManagerImpl implements apComparator = new AttachmentPointComparator(); floodlightProvider.addOFMessageListener(OFType.PACKET_IN, this); + floodlightProvider.addHAListener(this); flowReconcileMgr.addFlowReconcileListener(this); Runnable ecr = new Runnable() { diff --git a/src/main/java/net/floodlightcontroller/topology/TopologyManager.java b/src/main/java/net/floodlightcontroller/topology/TopologyManager.java index e823e55dc0b88cc2ff8b210326b83894d8483154..26374bf6855ff89c29abe846c375216ceb9f951b 100644 --- a/src/main/java/net/floodlightcontroller/topology/TopologyManager.java +++ b/src/main/java/net/floodlightcontroller/topology/TopologyManager.java @@ -603,6 +603,7 @@ public class TopologyManager implements restApi.addRestletRoutable(new TopologyWebRoutable()); newInstanceTask.reschedule(1, TimeUnit.MILLISECONDS); floodlightProvider.addOFMessageListener(OFType.PACKET_IN, this); + floodlightProvider.addHAListener(this); } // ****************