From a203ecad6c996665d503d11474ca5981b5621abd Mon Sep 17 00:00:00 2001
From: mo khan <mo@mokhan.ca>
Date: Mon, 2 Feb 2015 22:19:05 -0700
Subject: parse event as json.g

---
 lib/tasks/rabbitmq.rake | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)
 create mode 100644 lib/tasks/rabbitmq.rake

(limited to 'lib')

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
-- 
cgit v1.2.3