# File lib/nanite/amqp.rb, line 24 def recover requeue = false @mq.callback{ @mq.send Protocol::Basic::Recover.new({ :requeue => requeue }) } self end