commit d6dbb95e458f9bcca2091f2add58d62901f3ac1e
author Toshio Koide <t-koide@onlab.us> Fri Aug 22 14:29:04 2014 -0700
committer Saurav Das <sauravdas@alumni.stanford.edu> Fri Sep 05 11:47:24 2014 -0700
tree 9463b5b9e5efffade1197e13149ae916854ae6ee
parent 168c3a3c0a2c914e0fb98d2378f72d1753403b84

Add FlowEventDispatcher and implement event handler of FlowManagerModule.

- Added FlowEventDispatcher to handle FlowManager's events.
- Changed visibility of FlowBatchStateChangedEvent, FlowStatesChangedEvent and
  FlowStateChange classes to public.
- Implemented addListener() and removeListener() methods on FlowManagerModule.
- It is needed for Intent runtime service
  because it uses event handler of FlowManagerModule.
- This task is a preperation for ONOS-1691 and ONOS-1739.

Change-Id: I9c76d8c0dc06469698b087849f066b8531dd8736

src/main/java/net/onrc/onos/core/flowmanager/FlowManagerModule.java

diff --git a/src/main/java/net/onrc/onos/core/flowmanager/FlowManagerModule.java b/src/main/java/net/onrc/onos/core/flowmanager/FlowManagerModule.java
index ccf6081..39499f4 100644
--- a/src/main/java/net/onrc/onos/core/flowmanager/FlowManagerModule.java
+++ b/src/main/java/net/onrc/onos/core/flowmanager/FlowManagerModule.java
@@ -52,6 +52,7 @@
     private ISharedCollectionsService sharedCollectionService;
     private FlowMap flowMap;
     private FlowBatchMap flowBatchMap;
+    private FlowEventDispatcher flowEventDispatcher;
 
     @Override
     public Collection<Class<? extends IFloodlightService>> getModuleServices() {
@@ -96,6 +97,9 @@
 
         flowMap = new SharedFlowMap(sharedCollectionService);
         flowBatchMap = new SharedFlowBatchMap(sharedCollectionService);
+        flowEventDispatcher =
+                new FlowEventDispatcher(flowMap, flowBatchMap, matchActionService);
+        flowEventDispatcher.start();
     }
 
     /**
@@ -172,14 +176,12 @@
 
     @Override
     public void addListener(FlowManagerListener listener) {
-        // TODO Auto-generated method stub
-
+        flowEventDispatcher.addListener(listener);
     }
 
     @Override
     public void removeListener(FlowManagerListener listener) {
-        // TODO Auto-generated method stub
-
+        flowEventDispatcher.removeListener(listener);
     }
 
     private MatchActionOperations createNewMatchActionOperations() {