add rabbit bindings for queries.

3 files changed, 18 insertions, 0 deletions

diff --git a/Procfile b/Procfile
index fa0f511..25a5ae0 100644
--- a/Procfile
+++ b/Procfile
@@ -1,3 +1,4 @@
 web: rails s
 event_intake: env WORKERS=EventIntake rake sneakers:run
 poke: env WORKERS=Poke rake sneakers:run
+cloud_queries: env WORKERS=CloudQueries rake sneakers:run
diff --git a/app/workers/cloud_queries.rb b/app/workers/cloud_queries.rb
new file mode 100644
index 0000000..f9ebe48
--- /dev/null
+++ b/app/workers/cloud_queries.rb
@@ -0,0 +1,12 @@
+require 'json'
+
+class CloudQueries
+  include Sneakers::Worker
+  from_queue "worker.queries"
+
+  def work(json)
+    logger.info "Query for: #{json.inspect}"
+
+    ack!
+  end
+end
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