Coverage for docs / docs_src / getting_started / routers / rabbit / delay_equal.py: 69%

1from faststream import FastStream (empty)

2from faststream.rabbit import RabbitBroker, RabbitRouter (empty)

3 

4broker = RabbitBroker("amqp://guest:guest@localhost:5672/") (empty)

5app = FastStream(broker) (empty)

6 

7router = RabbitRouter() (empty)

8 

9@router.subscriber("test-queue") (empty)

10@router.publisher("outer-queue") (empty)

11async def handle(name: str, user_id: int): (empty)

12 assert name == "John" 

13 assert user_id == 1 

14 return "Hi!" 

15 

16broker.include_router(router) (empty)

17 

18@app.after_startup (empty)

19async def test(): (empty)

20 await broker.publish({"name": "John", "user_id": 1}, queue="test-queue")