summaryrefslogtreecommitdiff
path: root/app/workers
diff options
context:
space:
mode:
Diffstat (limited to 'app/workers')
-rw-r--r--app/workers/events_worker.rb8
1 files changed, 6 insertions, 2 deletions
diff --git a/app/workers/events_worker.rb b/app/workers/events_worker.rb
index 491ce87..fc3df31 100644
--- a/app/workers/events_worker.rb
+++ b/app/workers/events_worker.rb
@@ -1,9 +1,13 @@
+require 'json'
+
class EventsWorker
include Sneakers::Worker
from_queue "dashboard.events", env: nil
- def work(raw_post)
- Event.create!(raw_post)
+ def work(event_json)
+ logger.info event_json
+ event = Event.create!(JSON.parse(event_json))
+ logger.info("Create Event: #{event.id}")
ack!
end
end