publish message to rabbit to instead of creating a new event.

1 files changed, 16 insertions, 0 deletions

diff --git a/app/services/publisher.rb b/app/services/publisher.rb
new file mode 100644
index 0000000..ef940e8
--- /dev/null
+++ b/app/services/publisher.rb
@@ -0,0 +1,16 @@
+class Publisher
+  def self.publish(exchange, message = {})
+    exchange = channel.fanout("malwer.#{exchange}")
+    exchange.publish(message.to_json)
+  end
+
+  def self.channel
+    @channel ||= connection.create_channel
+  end
+
+  def self.connection
+    @connection ||= Bunny.new.tap do |connection|
+      connection.start
+    end
+  end
+end