diff options
| author | mo khan <mo@mokhan.ca> | 2015-02-03 22:18:55 -0700 |
|---|---|---|
| committer | mo khan <mo@mokhan.ca> | 2015-02-03 22:18:55 -0700 |
| commit | 5b4c048230302c4f692d011c747bb5c4da72e856 (patch) | |
| tree | 22a26ac187d8afc8ee387f47c12e66b49c238d98 /lib/tasks | |
| parent | 3371919560ef37fac3f59c95ad4cf2f6a472ef57 (diff) | |
add rabbit bindings for queries.
Diffstat (limited to 'lib/tasks')
| -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 |