parse event as json.g

2 files changed, 24 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
diff --git a/lib/tasks/rabbitmq.rake b/lib/tasks/rabbitmq.rake
new file mode 100644
index 0000000..6c8e3d2
--- /dev/null
+++ b/lib/tasks/rabbitmq.rake
@@ -0,0 +1,18 @@
+namespace :rabbitmq do
+  desc "setup rabbitmq routing"
+  task setup: :environment do
+    require "bunny"
+    connection = Bunny.new
+    connection.start
+    channel = connection.create_channel
+
+    # create exchange
+    exchange = channel.fanout("malwer.events")
+
+    # get or create queue (note the durable setting)
+    queue = channel.queue("dashboard.events", durable: true)
+    # bind queue to exchange
+    queue.bind("malwer.events")
+    connection.close
+  end
+end