poke disposition in worker.

1 files changed, 7 insertions, 4 deletions

diff --git a/lib/tasks/rabbitmq.rake b/lib/tasks/rabbitmq.rake
index 185f993..42cfce9 100644
--- a/lib/tasks/rabbitmq.rake
+++ b/lib/tasks/rabbitmq.rake
@@ -6,13 +6,16 @@ namespace :rabbitmq do
     connection.start
     channel = connection.create_channel
 
-    # create exchange
+    # event intake bindings
     exchange = channel.fanout("malwer.events")
-
-    # get or create queue (note the durable setting)
     queue = channel.queue("worker.events", durable: true)
-    # bind queue to exchange
     queue.bind("malwer.events")
+
+    # poke bindings
+    exchange = channel.fanout("malwer.poke")
+    queue = channel.queue("worker.poke", durable: true)
+    queue.bind("malwer.poke")
+
     connection.close
   end
 end