Function main

tools/queue_consumer.py:60–69

(queue, exchange, routing_key="#")

def main(queue, exchange, routing_key="#"):
    exchange = Exchange(exchange, type="topic")
    queue = Queue(
        name=queue, exchange=exchange, routing_key=routing_key, auto_delete=True
    )

    with transport_utils.get_connection() as connection:
        connection.connect()
        watcher = QueueConsumer(connection=connection, queue=queue)
        watcher.run()


if __name__ == "__main__":