diff --git a/neutron_taas/services/taas/agents/ovs/agent.py b/neutron_taas/services/taas/agents/ovs/agent.py
index 3993ba16..80c61cb3 100755
--- a/neutron_taas/services/taas/agents/ovs/agent.py
+++ b/neutron_taas/services/taas/agents/ovs/agent.py
@@ -58,7 +58,7 @@ def main():
     # Set up RPC
     mgr = taas_ovs_agent.TaasOvsAgentRpcCallback(cfg.CONF)
     endpoints = [mgr]
-    conn = n_rpc.create_connection(new=True)
+    conn = n_rpc.create_connection()
     conn.create_consumer(topics.TAAS_AGENT, endpoints, fanout=False)
     conn.consume_in_threads()
 
diff --git a/neutron_taas/services/taas/taas_plugin.py b/neutron_taas/services/taas/taas_plugin.py
index d247886d..454ff6d1 100755
--- a/neutron_taas/services/taas/taas_plugin.py
+++ b/neutron_taas/services/taas/taas_plugin.py
@@ -95,7 +95,7 @@ class TaasPlugin(taas_db.Tass_db_Mixin):
         LOG.debug("TAAS PLUGIN INITIALIZED")
         self.endpoints = [TaasCallbacks(self)]
 
-        self.conn = n_rpc.create_connection(new=True)
+        self.conn = n_rpc.create_connection()
         self.conn.create_consumer(
             topics.TAAS_PLUGIN, self.endpoints, fanout=False)
         self.conn.consume_in_threads()