Commit b33fc1e

mo khan <mo@mokhan.ca>
2015-02-03 23:49:38
automatically bind worker to events exchange.
main
1 parent 7ee72d2
Changed files (2)
app
workers
events_worker.rb
config
initializers
sneakers.rb
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
config/initializers/sneakers.rb
@@ -1,6 +1,6 @@
 require 'sneakers/metrics/logging_metrics'
 
 Sneakers.configure({
-  metrics: Sneakers::Metrics::LoggingMetrics.new
+  metrics: Sneakers::Metrics::LoggingMetrics.new,
 })
 Sneakers.logger.level = Logger::INFO