# 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