diff options
| author | mo khan <mo@mokhan.ca> | 2015-08-14 14:57:38 -0600 |
|---|---|---|
| committer | mo khan <mo@mokhan.ca> | 2015-08-14 14:57:38 -0600 |
| commit | 63a8f2fb3af4eb4e61625289cd029e3702afaa43 (patch) | |
| tree | 2ba8cb3c52dd2008f3f9ad9e4ed0821ef2fbf019 /lib | |
| parent | b20d909dee89d67fd1145ed3b2d57e55a67282d5 (diff) | |
create binding for cassandra worker.
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/tasks/rabbitmq.rake | 4 |
1 files changed, 4 insertions, 0 deletions
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 |