class SimpleRabbit::Publisher
Public Class Methods
publish(queue_name, message)
click to toggle source
# File lib/simple_rabbit/publisher.rb, line 5 def self.publish(queue_name, message) raise ConnectionNotEstablished unless $simplerabbit_connection queue = $simplerabbit_channel.queue(queue_name, durable: true) queue.publish(message, persistent: true) end