2014-09-11 2 views
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'])>"])> 

Здесь находится имя очереди. Что это за вещь? Как получить имя очереди?

+2

'frame.method.queue' ??? – Vor

+0

@Ввойте этому ответу. – opyate

ответ

1

Вы можете объявить уникальное имя, используя frame.method.queue.

 Смежные вопросы

  • Нет связанных вопросов^_^