diff --git a/src/main/java/net/onrc/onos/api/flowmanager/FlowBatchStateChangedEvent.java b/src/main/java/net/onrc/onos/api/flowmanager/FlowBatchStateChangedEvent.java
index 7b169e6..243d276 100644
--- a/src/main/java/net/onrc/onos/api/flowmanager/FlowBatchStateChangedEvent.java
+++ b/src/main/java/net/onrc/onos/api/flowmanager/FlowBatchStateChangedEvent.java
@@ -18,7 +18,7 @@
      * @param current the current state of the flow batch operation
      * @param previous the previous state of the flow batch operation
      */
-    FlowBatchStateChangedEvent(long time, FlowBatchHandle handle,
+    public FlowBatchStateChangedEvent(long time, FlowBatchHandle handle,
             FlowBatchState current, FlowBatchState previous) {
         this.time = time;
         this.handle = handle;
diff --git a/src/main/java/net/onrc/onos/api/flowmanager/FlowStateChange.java b/src/main/java/net/onrc/onos/api/flowmanager/FlowStateChange.java
index 9d7f0d6..5568ec1 100644
--- a/src/main/java/net/onrc/onos/api/flowmanager/FlowStateChange.java
+++ b/src/main/java/net/onrc/onos/api/flowmanager/FlowStateChange.java
@@ -15,7 +15,7 @@
      * @param current the current state of the flow
      * @param previous the previous state of the flow
      */
-    FlowStateChange(FlowId flowId, FlowState current, FlowState previous) {
+    public FlowStateChange(FlowId flowId, FlowState current, FlowState previous) {
         this.flowId = flowId;
         this.current = current;
         this.previous = previous;
diff --git a/src/main/java/net/onrc/onos/api/flowmanager/FlowStatesChangedEvent.java b/src/main/java/net/onrc/onos/api/flowmanager/FlowStatesChangedEvent.java
index d078fcb..8a9cab4 100644
--- a/src/main/java/net/onrc/onos/api/flowmanager/FlowStatesChangedEvent.java
+++ b/src/main/java/net/onrc/onos/api/flowmanager/FlowStatesChangedEvent.java
@@ -19,7 +19,7 @@
      * @param time the time at which the event was created in milliseconds since start of epoch
      * @param changes the set of {@link FlowStateChange} objects
      */
-    FlowStatesChangedEvent(long time, Set<FlowStateChange> changes) {
+    public FlowStatesChangedEvent(long time, Set<FlowStateChange> changes) {
         this.time = time;
         this.changes = ImmutableSet.copyOf(checkNotNull(changes));
     }
diff --git a/src/main/java/net/onrc/onos/core/flowmanager/FlowEventDispatcher.java b/src/main/java/net/onrc/onos/core/flowmanager/FlowEventDispatcher.java
new file mode 100644
index 0000000..808106a
--- /dev/null
+++ b/src/main/java/net/onrc/onos/core/flowmanager/FlowEventDispatcher.java
@@ -0,0 +1,126 @@
+package net.onrc.onos.core.flowmanager;
+
+import java.util.EventListener;
+import java.util.concurrent.CopyOnWriteArraySet;
+
+import net.onrc.onos.api.flowmanager.Flow;
+import net.onrc.onos.api.flowmanager.FlowBatchHandle;
+import net.onrc.onos.api.flowmanager.FlowBatchId;
+import net.onrc.onos.api.flowmanager.FlowBatchOperation;
+import net.onrc.onos.api.flowmanager.FlowBatchState;
+import net.onrc.onos.api.flowmanager.FlowBatchStateChangedEvent;
+import net.onrc.onos.api.flowmanager.FlowId;
+import net.onrc.onos.api.flowmanager.FlowManagerListener;
+import net.onrc.onos.api.flowmanager.FlowState;
+import net.onrc.onos.api.flowmanager.FlowStateChange;
+import net.onrc.onos.api.flowmanager.FlowStatesChangedEvent;
+import net.onrc.onos.core.matchaction.MatchActionService;
+
+import com.google.common.collect.Sets;
+
+/**
+ * Manages flow manager related events.
+ */
+public class FlowEventDispatcher implements
+        EventListener, FlowMapEventListener, FlowBatchMapEventListener {
+    private final FlowMap flowMap;
+    private final FlowBatchMap flowBatchMap;
+    private final MatchActionService maService;
+    private CopyOnWriteArraySet<FlowManagerListener> listeners;
+
+    /**
+     * Creates an instance using {@link FlowMap}, {@link FlowBatchMap} and
+     * {@link MatchActionService}.
+     *
+     * @param flowMap the {@link FlowMap} object
+     * @param flowBatchMap the {@link FlowBatchMap} object
+     * @param maService the {@link MatchActionService} object
+     */
+    FlowEventDispatcher(FlowMap flowMap, FlowBatchMap flowBatchMap,
+            MatchActionService maService) {
+        this.flowMap = flowMap;
+        this.flowBatchMap = flowBatchMap;
+        this.maService = maService;
+        this.listeners = new CopyOnWriteArraySet<>();
+    }
+
+    /**
+     * Adds the event listener.
+     *
+     * @param listener the listener to be added
+     */
+    void addListener(FlowManagerListener listener) {
+        listeners.add(listener);
+    }
+
+    /**
+     * Removes the event listener.
+     *
+     * @param listener the listener to be removed
+     */
+    void removeListener(FlowManagerListener listener) {
+        listeners.remove(listener);
+    }
+
+    /**
+     * Starts listening flow manager related events.
+     */
+    void start() {
+        maService.addEventListener(this);
+        flowMap.addListener(this);
+        flowBatchMap.addListener(this);
+    }
+
+    /**
+     * Stops listening flow manager related events.
+     */
+    void stop() {
+        maService.removeEventListener(this);
+        flowMap.removeListener(this);
+        flowBatchMap.removeListener(this);
+    }
+
+    @Override
+    public void flowAdded(FlowId id, Flow flow) {
+        // do nothing. (This event is not used for now)
+    }
+
+    @Override
+    public void flowRemoved(FlowId id) {
+        // do nothing. (This event is not used for now)
+    }
+
+    @Override
+    public void flowStateChanged(FlowId id, FlowState oldState, FlowState currentState) {
+        FlowStateChange stateChange = new FlowStateChange(id, currentState, oldState);
+        long time = System.currentTimeMillis();
+        FlowStatesChangedEvent event =
+                new FlowStatesChangedEvent(time, Sets.newHashSet(stateChange));
+        for (FlowManagerListener e : listeners) {
+            e.flowStatesChanged(event);
+        }
+    }
+
+    @Override
+    public void flowBatchOperationAdded(FlowBatchId id, FlowBatchOperation flowOp) {
+        // do nothing. (This event is not used for now)
+    }
+
+    @Override
+    public void flowBatchOperationRemoved(FlowBatchId id) {
+        // do nothing. (This event is not used for now)
+    }
+
+    @Override
+    public void flowBatchOperationStateChanged(FlowBatchId id, FlowBatchState oldState,
+            FlowBatchState currentState) {
+        FlowBatchHandle handle = new FlowBatchHandleImpl(flowBatchMap, id);
+        long time = System.currentTimeMillis();
+        FlowBatchStateChangedEvent event = new FlowBatchStateChangedEvent(time, handle,
+                currentState, currentState);
+
+        for (FlowManagerListener e : listeners) {
+            e.flowBatchStateChanged(event);
+        }
+    }
+}
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() {