from aio_pika.exceptions import AMQPConnectionError

from kernel.rabbitmq.exception.rabbitmq_exception import RabbitMQException


class ConnectionNotEstablished(RabbitMQException, AMQPConnectionError):
    pass