@synchronized('lock')
    def queue_declare(self, queue='', passive=False, durable=False, exclusive=False,
                      auto_delete=True, nowait=False,
                      arguments=None):
        arguments = arguments or {}
        args = AMQPWriter()
        args.write_short(0)
        args.write_shortstr(queue)
        args.write_bit(passive)
        args.write_bit(durable)
        args.write_bit(exclusive)
        args.write_bit(auto_delete)
        args.write_bit(nowait)
        args.write_table(arguments)
        self._send_method(Method(spec.Queue.Declare, args))

        if not nowait:
            return self.wait(spec.Queue.DeclareOk)
Declare queue, create if needed
dataset/ETHPy150Open veegee/amqpy/amqpy/channel.py/Channel.queue_declare