From b33fc1ee35bc0ee8d03645efac5ff4f844abc53f Mon Sep 17 00:00:00 2001
From: mo khan <mo@mokhan.ca>
Date: Tue, 3 Feb 2015 16:49:38 -0700
Subject: automatically bind worker to events exchange.

---
 app/workers/events_worker.rb | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

(limited to 'app/workers')

diff --git a/app/workers/events_worker.rb b/app/workers/events_worker.rb
index 4f69ce9..2e44b12 100644
--- a/app/workers/events_worker.rb
+++ b/app/workers/events_worker.rb
@@ -2,10 +2,13 @@ require 'json'
 
 class EventsWorker
   include Sneakers::Worker
-  from_queue "dashboard.events",
+  from_queue "worker.events",
+    durable: true,
+    ack: true,
     threads: 50,
     prefetch: 50,
-    timeout_job_after: 1
+    timeout_job_after: 1,
+    exchange: "malwer.events"
 
   def work(event_json)
     logger.info event_json
-- 
cgit v1.2.3