# File lib/amqp/queue.rb, line 403 def receive(headers, body) headers = AMQP::Header.new(@mq, headers) unless headers.nil? if cb = (@on_msg || @on_pop) cb.call *(cb.arity == 1 ? [body] : [headers, body]) end end