From 2085d8aecbfb095bbf9989a56dd74dc89f1d2a3e Mon Sep 17 00:00:00 2001 From: mo khan Date: Tue, 3 Feb 2015 21:30:13 -0700 Subject: add association from agents to events. --- app/workers/event_intake.rb | 13 +++++++++++++ app/workers/events_worker.rb | 13 ------------- 2 files changed, 13 insertions(+), 13 deletions(-) create mode 100644 app/workers/event_intake.rb delete mode 100644 app/workers/events_worker.rb (limited to 'app/workers') diff --git a/app/workers/event_intake.rb b/app/workers/event_intake.rb new file mode 100644 index 0000000..7e70497 --- /dev/null +++ b/app/workers/event_intake.rb @@ -0,0 +1,13 @@ +require 'json' + +class EventIntake + 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 diff --git a/app/workers/events_worker.rb b/app/workers/events_worker.rb deleted file mode 100644 index dc85009..0000000 --- a/app/workers/events_worker.rb +++ /dev/null @@ -1,13 +0,0 @@ -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 -- cgit v1.2.3