0
Я после asynchronous consumer example, и я хочу объявить очереди сервера именем следующим образом:Использование pika в асинхронном режиме, как получить имя очереди с именем сервера?
channel.queue_declare(on_queue_declareok, '')
Мой обратный вызов выглядит следующим образом:
def on_queue_declareok(frame):
queue_name = ???? # What goes here?
channel.queue_bind(on_bindok, queue_name, EXCHANGE_NAME, ROUTING_KEY)
Как получить сервер сгенерированных имя из параметра frame
. Если я распечатаю его, это выглядит так:
<METHOD(['frame_type=1', 'channel_number=1',
"method=<Queue.DeclareOk(['queue=amq.gen-NqdbEFHZdrtC4iLNdJpbjQ',
'message_count=0', 'consumer_count=0'])>"])>
Здесь находится имя очереди. Что это за вещь? Как получить имя очереди?
'frame.method.queue' ??? – Vor
@Ввойте этому ответу. – opyate