docs (airtai#1327): correct RMQ exhcanges behavior (airtai#1328)

aKardasz · Mar 30, 2024 · 1121684 · 1121684
1 parent 060f199
commit 1121684
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/docs/docs/en/rabbit/examples/fanout.md b/docs/docs/en/rabbit/examples/fanout.md
@@ -12,7 +12,7 @@ search:
 
 The **Fanout** Exchange is an even simpler, but slightly less popular way of routing in *RabbitMQ*. This type of `exchange` sends messages to all queues subscribed to it, ignoring any arguments of the message.
 
-At the same time, if the queue listens to several consumers, messages will also be distributed among them.
+At the same time, if the queue listens to several consumers, messages will also be distributed among them (default [scaling mechanism](../direct#scaling){.internal-link}).
 
 ## Example
 

diff --git a/docs/docs/en/rabbit/examples/headers.md b/docs/docs/en/rabbit/examples/headers.md
@@ -12,7 +12,7 @@ search:
 
 The **Header** Exchange is the most complex and flexible way to route messages in *RabbitMQ*. This `exchange` type sends messages to queues according by matching the queue binding arguments with message headers.
 
-At the same time, if several consumers are subscribed to the queue, messages will also be distributed among them.
+At the same time, if the queue listens to several consumers, messages will also be distributed among them (default [scaling mechanism](../direct#scaling){.internal-link}).
 
 ## Example
 

diff --git a/docs/docs/en/rabbit/examples/topic.md b/docs/docs/en/rabbit/examples/topic.md
@@ -12,7 +12,7 @@ search:
 
 The **Topic** Exchange is a powerful *RabbitMQ* routing tool. This type of `exchange` sends messages to the queue in accordance with the *pattern* specified when they are connected to `exchange` and the `routing_key` of the message itself.
 
-At the same time, if several consumers are subscribed to the queue, messages will be distributed among them.
+At the same time, if the queue listens to several consumers, messages will also be distributed among them (default [scaling mechanism](../direct#scaling){.internal-link}).
 
 ## Example
 

diff --git a/docs/docs_src/rabbit/subscription/fanout.py b/docs/docs_src/rabbit/subscription/fanout.py
@@ -27,7 +27,7 @@ async def base_handler3(logger: Logger):
 
 @app.after_startup
 async def send_messages():
-    await broker.publish(exchange=exch)  # handlers: 1, 2, 3
-    await broker.publish(exchange=exch)  # handlers: 1, 2, 3
-    await broker.publish(exchange=exch)  # handlers: 1, 2, 3
-    await broker.publish(exchange=exch)  # handlers: 1, 2, 3
+    await broker.publish(exchange=exch)  # handlers: 1, 3
+    await broker.publish(exchange=exch)  # handlers: 2, 3
+    await broker.publish(exchange=exch)  # handlers: 1, 3
+    await broker.publish(exchange=exch)  # handlers: 2, 3