diff --git a/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowEventHandler.java b/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowEventHandler.java
index 7118e41..de372ef 100644
--- a/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowEventHandler.java
+++ b/src/main/java/net/onrc/onos/ofcontroller/flowmanager/FlowEventHandler.java
@@ -640,7 +640,8 @@
 
 	// Get my Flows
 	Collection<FlowPath> myFlows =
-	    FlowDatabaseOperation.getFlows(dbHandler, shouldFetchMyFlowIds);
+	    ParallelFlowDatabaseOperation.getFlows(dbHandler,
+						   shouldFetchMyFlowIds);
 
 	for (FlowPath flowPath : myFlows) {
 	    fixFlowFromDatabase(flowPath);