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