@synchronized('lock')
    def basic_get(self, queue='', no_ack=False):
        args = AMQPWriter()
        args.write_short(0)
        args.write_shortstr(queue)
        args.write_bit(no_ack)
        self._send_method(Method(spec.Basic.Get, args))
        return self.wait_any([spec.Basic.GetOk, spec.Basic.GetEmpty])
Accept-Language available?
dataset/ETHPy150Open veegee/amqpy/amqpy/channel.py/Channel.basic_get--crossover with--dataset/ETHPy150Open benoitc/dj-webmachine/webmachine/decisions.py/d05