parse event as json.g

1 files changed, 18 insertions, 0 deletions

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