diff options
Diffstat (limited to 'lib/tasks/rabbitmq.rake')
| -rw-r--r-- | lib/tasks/rabbitmq.rake | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/lib/tasks/rabbitmq.rake b/lib/tasks/rabbitmq.rake index 42cfce9..0fbe1c7 100644 --- a/lib/tasks/rabbitmq.rake +++ b/lib/tasks/rabbitmq.rake @@ -16,6 +16,11 @@ namespace :rabbitmq do queue = channel.queue("worker.poke", durable: true) queue.bind("malwer.poke") + # cloud queries bindings + exchange = channel.fanout("malwer.queries") + queue = channel.queue("worker.queries", durable: true) + queue.bind("malwer.queries") + connection.close end end |