muhammetfaik · October 1, 2017 12:07 · Oct 1, 2017
diff --git a/gistfile1.txt b/gistfile1.txt
@@ -0,0 +1,26 @@
+class Publisher
+ # In order to publish message we need a exchange name.
+ # Note that RabbitMQ does not care about the payload -
+ # we will be using JSON-encoded strings
+ def self.publish(exchange, message = {})
+   # grab the fanout exchange
+   x = channel.fanout("dbcountermain#{exchange}")
+   # and simply publish message
+   x.publish(message.to_json)
+ end
+
+ def self.channel
+   @channel ||= connection.create_channel
+ end
+
+ # We are using default settings here
+ # The `Bunny.new(...)` is a place to
+ # put any specific RabbitMQ settings
+ # like host or port
+ def self.connection
+   @connection ||= Bunny.new.tap do |c|
+     c.start
+   end
+ end
+end
+
No results found