aio_pika, aio_pika в одном приложении или

import logging
import aio_pika
from aio_pika.exceptions import AMQPError
from aiogram import Bot, Dispatcher, executor
from aiogram.types import Message
import asyncio
import json
 
# Конфигурация
RABBITMQ_USER = 'user'
RABBITMQ_PASS = 'pass'
RABBITMQ_HOST = 'localhost'
QUEUE_EVENT = 'event_queue'
 
# Настройка логирования
logging.basicConfig(level=logging.INFO)
 
class RabbitConsumer:
    def __init__(self):
        self._url = f"amqp://{RABBITMQ_USER}:{RABBITMQ_PASS}@{RABBITMQ_HOST}/"
        self.stop_event = asyncio.Event()
 
    async def rabbitmq_consumer(self):
        while not self.stop_event.is_set():
            try:
                logging.info(f'Запуск RabbitMQ: {self._url}')
                connection = await aio_pika.connect_robust(self._url)
                async with connection:
                    channel = await connection.channel()
                    queue = await channel.declare_queue(QUEUE_EVENT, durable=True)
                    async for message in queue:
                        async with message.process():
                            try:
                                text = message.body.decode()
                                await self.event_worker(json.loads(text))
                            except Exception as e:
                                logging.error(f"Ошибка обработки сообщения: {e}")
            except AMQPError as e:
                logging.error(f"Ошибка подключения к RabbitMQ: {e}")
            except Exception as e:
                logging.error(f"Неизвестная ошибка при подключении к RabbitMQ: {e}")
            await asyncio.sleep(5)
 
    async def event_worker(self, event):
        # Обработка события
        logging.info(f"Обработано событие: {event}")
 
    async def on_shutdown(self):
        logging.info("Остановка RabbitMQ")
        self.stop_event.set()
 
# Инициализация бота
bot = Bot(token="YOUR_BOT_TOKEN")
dp = Dispatcher(bot)
 
@dp.message_handler()
async def echo(message: Message):
    await message.answer(message.text)
 
async def on_startup(dp):
    logging.info("Запуск бота")
    rabbit_consumer = RabbitConsumer()
    dp.bot['rabbit_consumer'] = rabbit_consumer
    asyncio.create_task(rabbit_consumer.rabbitmq_consumer())
 
async def on_shutdown(dp):
    logging.info("Остановка бота")
    rabbit_consumer = dp.bot['rabbit_consumer']
    await rabbit_consumer.on_shutdown()
 
if __name__ == '__main__':
    executor.start_polling(dp, on_startup=on_startup, on_shutdown=on_shutdown)