diff --git a/src/main/java/net/onrc/onos/core/flowprogrammer/FlowProgrammer.java b/src/main/java/net/onrc/onos/core/flowprogrammer/FlowProgrammer.java
index b5912d5..838533d 100644
--- a/src/main/java/net/onrc/onos/core/flowprogrammer/FlowProgrammer.java
+++ b/src/main/java/net/onrc/onos/core/flowprogrammer/FlowProgrammer.java
@@ -127,6 +127,7 @@
         if (ENABLE_FLOW_SYNC) {
             synchronizer.interrupt(sw);
         }
+        pusher.deleteQueue(sw, true);
     }
 
     @Override