class Ros::Console::Commands::RabbitMQ
Public Instance Methods
process()
click to toggle source
TODO: refactor
# File lib/ros/core/console.rb, line 110 def process return unless ENV['AMQP_URL'] record = { bucket: 'test', key: 'path/to/object' } conn = Bunny.new(ENV['AMQP_URL']) conn.start ch = conn.create_channel puts "#{record[:bucket]}/#{record[:key]}" puts ENV['AMQP_QUEUE_NAME'] puts record.merge!({ tenant: 'hsbc', environment: 'development' }) res = ch.default_exchange.publish("#{record[:bucket]}/#{record[:key]}", routing_key: ENV['AMQP_QUEUE_NAME'], headers: record.merge({ version: ENV['AMQP_VERSION'].to_s })) puts 'Here is output from bunny' puts res conn.close end