Как переиздать сообщения с pika и RabbitMQ

Question

Мне нужно прослушать сообщения RabbitMQ, немного обработать каждое сообщение и отправить его на другой обмен. Каждый пример, который я видел до сих пор, включает в себя либо это:

reader_connection.ioloop.start()

или это:

writer_connection.ioloop.start()

Поскольку мне нужно и получать, и отправлять сообщения, мне, вероятно, нужно запускать оба цикла одновременно. Есть ли способ, которым я мог бы сделать это?

Answer 1

Нет разницы между издателями и подписчиками. Вы можете публиковать и подписываться, используя то же соединение или другое (тогда вам нужно будет запустить ioloop для них обоих). Вы можете найти несколько примеров здесь: https://pika.readthedocs.org/en/0.10.0/examples/connecting_async.html