Remove new= argument from create_connection
It has been marked deprecated [1] and recently removed. [2] [1] I57b0229c2b6028796cd10bbbfc9b166cf8a6dab0 [2] I550c65861a8664068e340b7b4689b2345951e888 Closes-Bug: #1570202 Closes-Bug: #1570840 Change-Id: Ia384be8d13431dbd6327a6bb689622d8d3731538
This commit is contained in:
parent
a7d933dec0
commit
75b40370cf
@ -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()
|
||||
|
||||
|
@ -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()
|
||||
|
Loading…
Reference in New Issue
Block a user