app/workers/events_worker.rb


1
2
3
4
5
6
7
8
9
10
11
12
13

require 'json'

class EventsWorker
  include Sneakers::Worker
  from_queue "worker.events"

  def work(event_json)
    logger.info event_json
    event = Event.create!(JSON.parse(event_json))
    logger.info("Create Event: #{event.id}")
    ack!
  end
end