使用Bunny gem处理队列中的消息时正常关闭

Question

我使用Bunny gem通过AMQP消费消息。我的应用程序订阅了队列中的消息，这是一个永无止境的阻塞调用(通过订阅块)。我希望它能在进程中断时正常关闭(例如，终端中的ctrl+c )。正确的做法是什么？如果它正在处理当前消息，我希望它处理当前消息，然后跳出该块。

代码示例：

trap("INT") do 
  puts "Stopping now"
  Indexer.client.stop # ???
end

module Indexer
  extend self

  def run    
    client.queue('indexer.index').subscribe do |msg|
      # omitted
    end
  end

  def client
    @client ||= Bunny.new.tap(&:start)
  end

end

Indexer.run # runs forever

Answer 1

我知道这个问题已经有2年的历史了，你现在可能已经想明白了。话虽如此，我处理这件事的方式将是提出一个“我应该辞职吗？”在订阅循环的末尾检查，然后让SIGINT陷阱切换变量。Bunny本身在清理所有AMQP连接方面做得很好，所以你真的只需要担心退出时你自己的部分。