Commit 7ee72d2

mo khan <mo@mokhan.ca>
2015-02-03 23:33:52
add sneaker options.
main
1 parent a203eca
Changed files (2)
app
workers
events_worker.rb
config
initializers
sneakers.rb
app/workers/events_worker.rb
@@ -2,7 +2,10 @@ require 'json'
 
 class EventsWorker
   include Sneakers::Worker
-  from_queue "dashboard.events", env: nil
+  from_queue "dashboard.events",
+    threads: 50,
+    prefetch: 50,
+    timeout_job_after: 1
 
   def work(event_json)
     logger.info event_json
config/initializers/sneakers.rb
@@ -1,2 +1,6 @@
-Sneakers.configure({})
+require 'sneakers/metrics/logging_metrics'
+
+Sneakers.configure({
+  metrics: Sneakers::Metrics::LoggingMetrics.new
+})
 Sneakers.logger.level = Logger::INFO