Method close

src/core/rabbit_mq/producer.py:43–47

(self)

            raise

    async def close(self) -> None:
        if self._conn and not self._conn.is_closed:
            await self._conn.close()
            self._is_initialized = False
            self.logger.info("🚦 RabbitMQ producer closed")

    @property
    def is_connected(self) -> bool: