from __future__ import annotations


class MQError(RuntimeError):
    """Base MQ error."""


class MQConfigError(MQError):
    """Raised when MQ configuration is missing or invalid."""


class MQPublishError(MQError):
    """Raised when a message cannot be published."""