3 консюмера
Вот инит:
rmq_channel.exchange_declare(exchange=RABBITMQ_EXCHANGE, exchange_type=ExchangeType.fanout)
rmq_channel.queue_declare(queue=queue, durable=True)
rmq_channel.queue_bind(queue=queue, exchange=RABBITMQ_EXCHANGE, routing_key=routing_key)
Отправка сообщения:
rmq_channel.basic_publish(
exchange=RABBITMQ_EXCHANGE,
routing_key=routing_key,
body=json.dumps(body),
properties=properties,
)
Консюмер:
rmq_channel.basic_consume(
queue=RABBITMQ_SPIDER_DATA_QUEUE,
on_message_callback=self._spider_data_queue_callback,
)
Сообщение приходит только в 1 консюмер. В чём может быть причина?
Один консьюмер помечает сообщение как прочитанное
проблема в режиме работы ексчейнджа
Обсуждают сегодня