@@ -18,14 +18,14 @@ async def test() -> None:
18
18
## Configuration
19
19
20
20
AioPikaBroker parameters:
21
- ` url ` - url to rabbitmq. If None, "amqp://guest: guest @localhost:5672" is used.
22
- ` result_backend ` - custom result backend.
23
- ` task_id_generator ` - custom task_id genertaor.
24
- ` exchange_name ` - name of exchange that used to send messages.
25
- ` exchange_type ` - type of the exchange. Used only if ` declare_exchange ` is True.
26
- ` queue_name ` - queue that used to get incoming messages.
27
- ` routing_key ` - that used to bind that queue to the exchange.
28
- ` declare_exchange ` - whether you want to declare new exchange if it doesn't exist.
29
- ` qos ` - number of messages that worker can prefetch.
30
- ` max_connection_pool_size ` - maximum number of connections in pool.
31
- ` max_channel_pool_size ` - maximum number of channels for each connection.
21
+ * ` url ` - url to rabbitmq. If None, "amqp://guest: guest @localhost:5672" is used.
22
+ * ` result_backend ` - custom result backend.
23
+ * ` task_id_generator ` - custom task_id genertaor.
24
+ * ` exchange_name ` - name of exchange that used to send messages.
25
+ * ` exchange_type ` - type of the exchange. Used only if ` declare_exchange ` is True.
26
+ * ` queue_name ` - queue that used to get incoming messages.
27
+ * ` routing_key ` - that used to bind that queue to the exchange.
28
+ * ` declare_exchange ` - whether you want to declare new exchange if it doesn't exist.
29
+ * ` qos ` - number of messages that worker can prefetch.
30
+ * ` max_connection_pool_size ` - maximum number of connections in pool.
31
+ * ` max_channel_pool_size ` - maximum number of channels for each connection.
0 commit comments