Only one process of multiple processes receives it, use FANOUT

[v2boardbot]

consumer:

from faststream import FastStream, Logger
from faststream.rabbit import ExchangeType, RabbitBroker, RabbitExchange, RabbitQueue

broker = RabbitBroker()
app = FastStream(broker)

exch = RabbitExchange("exchange", auto_delete=True, type=ExchangeType.FANOUT)

queue_1 = RabbitQueue("test-q-1", auto_delete=True)


@broker.subscriber(queue_1, exch, no_ack=True)
async def base_handler1(logger: Logger):
    logger.info("base_handler1111")

consumer start command：faststream run main:app --workers 2

===========================
Producer:

import asyncio
from faststream import FastStream, Logger
from faststream.rabbit import ExchangeType, RabbitBroker, RabbitExchange, RabbitQueue

broker = RabbitBroker()
app = FastStream(broker)
exch = RabbitExchange("exchange", auto_delete=True, type=ExchangeType.FANOUT)


@app.after_startup
async def send_messages():
    for i in range(100):
        res = await broker.publish(exchange=exch)  # handlers: 1, 2, 3
        print(res)
        await asyncio.sleep(5)

Producer startup command: faststream run client:app

[Lancetnik]

FANOUT exchange deliveres message to all binded queues. So, to consume message double you should bind another queue to this exchange with another routing key/name.

The following setup should works fine

@broker.subscriber(queue_1, exch)
async def base_handler1(logger: Logger):
    ...
    
@broker.subscriber(queue_2, exch)  # another queue
async def base_handler1(logger: Logger):
    ...

RMQ message pipeline works the following way: EXCHANGE -> QUQEUE -> SUBSCRIBER
You tried to consume message multiple times from the same QUEUE, but it is impossible.

[Lancetnik]

Seems like I wrote documentation wrong...

[v2boardbot]

Then your document is wrong

[Lancetnik]

Yeah, I already fixing it. Seems like only code comments wrong.