Simple heartbeat example

simple_heartbeat.rb

require 'bunny'

b = Bunny.new(:logging => true, :heartbeat => 15)

b.start
q = b.queue('hb_test')

Thread.new do
  q.subscribe {|msg| puts msg[:payload]}
end

Thread.new do
  loop do
    sleep(b.heartbeat)
    b.send_heartbeat
  end
end

loop do
  sleep(2 * b.heartbeat)
  if b.message_in
    puts 'Still alive'
    b.message_in = false
  else
    puts 'Oh dear, no sign of life'
    exit
  end
end