Commit 8881848f by Guba Sándor

network: fix queues names

parent 2d99cd14
...@@ -152,12 +152,12 @@ class Interface(Model): ...@@ -152,12 +152,12 @@ class Interface(Model):
return iface return iface
def deploy(self): def deploy(self):
queue_name = self.instance.get_remote_queue_name('net') queue_name = self.instance.get_remote_queue_name('net', 'fast')
return net_tasks.create.apply_async(args=[self.get_vmnetwork_desc()], return net_tasks.create.apply_async(args=[self.get_vmnetwork_desc()],
queue=queue_name).get() queue=queue_name).get()
def shutdown(self): def shutdown(self):
queue_name = self.instance.get_remote_queue_name('net') queue_name = self.instance.get_remote_queue_name('net', 'fast')
return net_tasks.destroy.apply_async(args=[self.get_vmnetwork_desc()], return net_tasks.destroy.apply_async(args=[self.get_vmnetwork_desc()],
queue=queue_name).get() queue=queue_name).get()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment