Commit a5b223d

mo khan <mo@mokhan.ca>
2015-02-03 04:49:15
add sneakers worker.
1 parent b43701e
Changed files (4)
app/workers/events_worker.rb
@@ -0,0 +1,9 @@
+class EventsWorker
+  include Sneakers::Worker
+  from_queue "dashboard.events", env: nil
+
+  def work(raw_post)
+    Event.create!(raw_post)
+    ack! # we need to let queue know that message was received
+  end
+end
config/initializers/sneakers.rb
@@ -0,0 +1,2 @@
+Sneakers.configure({})
+Sneakers.logger.level = Logger::INFO
Procfile
@@ -0,0 +1,2 @@
+web: rails s
+worker: env WORKERS=EventsWorker rake sneakers:run
Rakefile
@@ -2,5 +2,6 @@
 # for example lib/tasks/capistrano.rake, and they will automatically be available to Rake.
 
 require File.expand_path('../config/application', __FILE__)
+require 'sneakers/tasks'
 
 Rails.application.load_tasks