From 63a8f2fb3af4eb4e61625289cd029e3702afaa43 Mon Sep 17 00:00:00 2001 From: mo khan Date: Fri, 14 Aug 2015 14:57:38 -0600 Subject: create binding for cassandra worker. --- lib/tasks/rabbitmq.rake | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'lib') diff --git a/lib/tasks/rabbitmq.rake b/lib/tasks/rabbitmq.rake index 22b401c..c7baa19 100644 --- a/lib/tasks/rabbitmq.rake +++ b/lib/tasks/rabbitmq.rake @@ -25,6 +25,10 @@ namespace :rabbitmq do # cloud queries bindings queue = channel.queue("worker.queries", durable: true) queue.bind(exchange, routing_key: 'events.scanned.#') + + # cassandra worker bindings + queue = channel.queue("worker.cassandra", durable: true) + queue.bind(exchange, routing_key: 'events.scanned.#') end connection.close -- cgit v1.2.3