(queue)
| 105 | migrate = partial(migrate, producer, queues=queues) |
| 106 | |
| 107 | def on_declare_queue(queue): |
| 108 | new_queue = queue(producer.channel) |
| 109 | new_queue.name = queues.get(queue.name, queue.name) |
| 110 | if new_queue.routing_key == queue.name: |
| 111 | new_queue.routing_key = queues.get(queue.name, |
| 112 | new_queue.routing_key) |
| 113 | if new_queue.exchange.name == queue.name: |
| 114 | new_queue.exchange.name = queues.get(queue.name, queue.name) |
| 115 | new_queue.declare() |
| 116 | |
| 117 | return start_filter(app, source, migrate, queues=queues, |
| 118 | on_declare_queue=on_declare_queue, **kwargs) |
nothing calls this directly
no test coverage detected
searching dependent graphs…