Fixed to use Faststream for an easier flow

[Ifechukwu001]

The PR implements FastStream for RabbitMQ communications.

To publish a message to RabbitMQ,

   from src.config.asgi import broker
   
   async publish_message(queue: str, message: [JSON serializable object (str, int, dict, list)]) -> None:
       await broker.publish(message, queue, persist=True)
       # Successfully published

To register a consumer from RabbitMQ,

    # src/api/services/ExampleService.py
    from faststream.rabbit import RabbitRouter
    
    EXAMPLE_ROUTER = RabbitRouter()
    
    # In a function
    @EXAMPLE_ROUTER.subscriber("queue")
    async def consume(message: [JSON serializable object (it will be checked as it uses pydantic to decode the message)]) -> None:
        print(message)
        
    # In a class
    class Example:
        
        @staticmethod
        @EXAMPLE_ROUTER.subscriber("queue")
        async def (message: [JSON serializable object (it will be checked as it uses pydantic to decode the message)]) -> None:
            print(message)

Then register the consumer in the src.api.services.external.RabbitMQRoutes as below

    # src/api/services/external/RabbitMQRoutes.py
    from src.config.asgi import broker
    
    from ..ExampleService import EXAMPLE_ROUTER
    
    
    broker.include_router(EXAMPLE_ROUTER)