MCPcopy Create free account
hub / github.com/dbunt1tled/python-fast-api / initialize

Method initialize

src/core/rabbit_mq/worker.py:15–19  ·  view source on GitHub ↗
(self, loop: asyncio.AbstractEventLoop, handlers: list[MessageHandler])

Source from the content-addressed store, hash-verified

13 self.logger = log
14
15 async def initialize(self, loop: asyncio.AbstractEventLoop, handlers: list[MessageHandler]) -> None:
16 await self.consumer.initialize(loop=loop)
17 for handler in handlers:
18 self.consumer.register_handler(handler)
19 self.logger.info("🚀 RabbitMQ worker initialized successfully")
20
21 async def start(self) -> None:
22 try:

Callers 2

executeMethod · 0.95
lifespanFunction · 0.45

Calls 2

register_handlerMethod · 0.80
infoMethod · 0.80

Tested by

no test coverage detected