diff --git a/TestON/drivers/common/api/controller/onosrestdriver.py b/TestON/drivers/common/api/controller/onosrestdriver.py
index ed7786c..2a62276 100644
--- a/TestON/drivers/common/api/controller/onosrestdriver.py
+++ b/TestON/drivers/common/api/controller/onosrestdriver.py
@@ -21,6 +21,7 @@
 import requests
 import types
 import sys
+from Queue import Queue
 
 from drivers.common.api.controllerdriver import Controller
 
@@ -1715,6 +1716,12 @@
             main.cleanup()
             main.exit()
 
+    def sendFlowBatchQueue(self, q=Queue(), ip="DEFAULT", port="DEFAULT", debug=False):
+        while True:
+            item = q.get()
+            self.sendFlowBatch(batch = item)
+            q.task_done()
+
     def removeFlowBatch( self, batch={},
                        ip="DEFAULT", port="DEFAULT" ):
         """