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