use a single topic exchange instead of multiple fanout exchanges.

1 files changed, 3 insertions, 3 deletions

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