Graceful shutdown of a ruby amqp (bunny) worker

trap_sigint.rb

#!/usr/bin/ruby
# правильный пример мягкого завершения обработки сообщений
require 'bunny'

$gameover = false
$nonstop  = Mutex.new

trap('INT') do
  STDERR.puts "Wanted interrupt."
  $gameover = true
end

trap('TERM') do
  STDERR.puts "Wanted termination."
  $gameover = true
end

$consumer = Bunny.new.start.create_channel.queue('trap').subscribe(block: false) do |di, props, body|
  $nonstop.lock
  puts "di: #{ di.inspect}\n props: #{ props.inspect }\n#{ body }\n"
  sleep(10)
  puts "КЦ"
  $nonstop.unlock
end

loop do
  if $gameover
    puts "So, let me finish this."
    sleep(0.5) while $nonstop.locked?
    $consumer.cancel
    break
  end
  print '.'
  sleep 1
end