amqp091_consumer.rb

#!/usr/bin/env ruby

Bundler.setup
require "bunny"

conn = Bunny.new
conn.start

ch   = conn.create_channel
q    = ch.queue("", exclusive: true)

q.bind(ch.topic("amq.topic"), routing_key: "builds").subscribe(block: true) do |_, _, payload|
  puts "Payload: #{payload}"
end

mqtt_publisher.rb

#!/usr/bin/env ruby

Bundler.setup
require "mqtt"

c = MQTT::Client.connect(
  remote_host: "127.0.0.1",
  remote_port: 1883,
  username: "guest",
  password: "guest")

loop do
  m = "Message @ #{Time.now.to_i}"
  c.publish("builds", m)
  puts "=> Published #{m}"
  sleep 0.2
end