python_infrastructure_exceptions.messaging
==========================================

.. py:module:: python_infrastructure_exceptions.messaging

.. autoapi-nested-parse::

   Message queue infrastructure exceptions.



Classes
-------

.. autoapisummary::

   python_infrastructure_exceptions.messaging.MessageQueueError


Module Contents
---------------

.. py:class:: MessageQueueError(message: str, details: str = None, broker: str = None, topic: str = None)

   Bases: :py:obj:`python_infrastructure_exceptions.base.InfrastructureException`


   Message 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")


   .. py:attribute:: broker
      :value: None



   .. py:attribute:: topic
      :value: None