Commit 6051853

mo khan <mo@mokhan.ca>
2015-02-03 23:55:26
fix binding.
main
1 parent 9cb0e6f
Changed files (1)
lib
tasks
rabbitmq.rake
lib/tasks/rabbitmq.rake
@@ -10,7 +10,7 @@ namespace :rabbitmq do
     exchange = channel.fanout("malwer.events")
 
     # get or create queue (note the durable setting)
-    queue = channel.queue("dashboard.events", durable: true)
+    queue = channel.queue("worker.events", durable: true)
     # bind queue to exchange
     queue.bind("malwer.events")
     connection.close