python_infrastructure_exceptions.messaging¶
Message queue infrastructure exceptions.
Classes¶
Message queue/broker infrastructure error. |
Module Contents¶
- class python_infrastructure_exceptions.messaging.MessageQueueError(message: str, details: str = None, broker: str = None, topic: str = None)¶
Bases:
python_infrastructure_exceptions.base.InfrastructureExceptionMessage queue/broker infrastructure error.
Use for: - Kafka broker unavailable - RabbitMQ connection failures - Message publish failures - Consumer group errors - Topic/queue not found
- Examples:
raise MessageQueueError(“Kafka broker unavailable”, details=”broker.example.com:9092”) raise MessageQueueError(“RabbitMQ connection failed”, details=”Connection refused”) raise MessageQueueError(“Message publish timeout”, details=”Topic: user-events”)
- broker = None¶
- topic = None¶