From 65145e6be87df7b0440fb98c11abc23a2b3c49ed Mon Sep 17 00:00:00 2001 From: mo khan Date: Sat, 7 Feb 2015 12:33:06 -0700 Subject: use a single topic exchange instead of multiple fanout exchanges. --- app/services/publisher.rb | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'app/services') diff --git a/app/services/publisher.rb b/app/services/publisher.rb index ef940e8..704f1e3 100644 --- a/app/services/publisher.rb +++ b/app/services/publisher.rb @@ -1,7 +1,7 @@ class Publisher - def self.publish(exchange, message = {}) - exchange = channel.fanout("malwer.#{exchange}") - exchange.publish(message.to_json) + def self.publish(routing_key, message = {}) + exchange = channel.topic("malwer") + exchange.publish(message.to_json, routing_key: routing_key) end def self.channel -- cgit v1.2.3