4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
# File 'lib/esp-commons/libraries/message_maker.rb', line 4
def self.make_message(queue_name, routing_key, *message)
Rails.logger.debug("MessageMaker: [#{queue_name.inspect}]: #{routing_key}(#{[*message].map(&:inspect).join(', ')})")
if Settings['amqp.url']
amqp_client = Bunny.new(Settings['amqp.url'], :logging => false)
amqp_client.start
exchange = amqp_client.exchange(queue_name, :type => :topic)
queue = amqp_client.queue(queue_name, :durable => true)
queue.bind(exchange, :key => '*')
exchange.publish(message.as_json.to_json, :key => routing_key, :persistent => true)
amqp_client.stop
else
if Rails.env.production?
raise 'Define amqp.url in config/settings.yml'
else
Rails.logger.warn 'MessageMaker: Define amqp.url in config/settings.yml'
end
end
end
|