Какой брокер сообщений был на прошлом проекте

На прошлом проекте использовали RabbitMQ — надежный брокер сообщений с поддержкой AMQP. Основные причины выбора:

• Гибкость (очереди, обменники, routing keys)
• Надежность (подтверждение доставки, persistence)
• Масштабируемость (кластеризация)

Пример подключения:

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='tasks')

def callback(ch, method, properties, body):
    print(f"Received: {body}")

channel.basic_consume(queue='tasks', on_message_callback=callback, auto_ack=True)
channel.start_consuming()

Также рассматривали Kafka для сценариев с высокой нагрузкой, но остановились на RabbitMQ из-за простоты и достаточной производительности для наших задач.