From 5b4c048230302c4f692d011c747bb5c4da72e856 Mon Sep 17 00:00:00 2001
From: mo khan <mo@mokhan.ca>
Date: Tue, 3 Feb 2015 22:18:55 -0700
Subject: add rabbit bindings for queries.

---
 lib/tasks/rabbitmq.rake | 5 +++++
 1 file changed, 5 insertions(+)

(limited to 'lib')

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
-- 
cgit v1.2.3