You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Every messages pushed to the RabbitMQ server uses the publiser confirms. This means that the message is only considered as sent when the server confirms it. This is a reliable way to ensure that the message is delivered to the server.
18
+
{% endhint %}
19
+
20
+
16
21
After that, you should configure the connection to the server in the `amqp` section. This configuration section
17
22
contains exactly one `addr` key with a [connection DSN](https://www.rabbitmq.com/uri-spec.html). The `TLS` configuration sits in the `amqp.tls` section and consists of the following options:
18
23
@@ -67,7 +72,7 @@ the queue settings, including those specific to AMQP.
67
72
version: "3"
68
73
69
74
amqp:
70
-
addr: amqp://guest:guest@127.0.0.1:5672
75
+
addr: amqp://guest:guest@127.0.0.1:5672
71
76
72
77
# AMQPS TLS configuration
73
78
#
@@ -210,7 +215,7 @@ from `pipe1` have been processed.
210
215
211
216
### Prefetch
212
217
213
-
`prefetch`- rabbitMQ QoS prefetch. See also ["prefetch-size"](https://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos.prefetch-size). Note that if you use a large number of workers and a small `prefetch` number, some of the workers may not be loaded with messages (jobs) due to the blocking nature of the prefetch. This would result in poor RoadRunner performance and waste of resources.
218
+
`prefetch`- rabbitMQ QoS prefetch. See also ["prefetch-size"](https://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.qos.prefetch-size). Note that if you use a large number of workers and a small `prefetch` number, some of the workers may not be loaded with messages (jobs) due to the blocking nature of the prefetch. This would result in poor RoadRunner performance and waste of resources.
214
219
215
220
### Queue
216
221
@@ -257,13 +262,13 @@ Read more about Nack in RabbitMQ official docs: https://www.rabbitmq.com/confirm
257
262
258
263
### Durable
259
264
260
-
`durable`- create a durable queue.
265
+
`durable`- create a durable queue.
261
266
262
267
Default: `false`
263
268
264
269
### Delete queue on stop
265
270
266
-
`delete_queue_on_stop`- delete the queue when the pipeline is stopped.
271
+
`delete_queue_on_stop`- delete the queue when the pipeline is stopped.
`exchange_auto_delete` - Auto-delete (exchange is deleted when last queue is unbound from it): [link](https://www.rabbitmq.com/tutorials/amqp-concepts.html#exchanges).
288
+
`exchange_auto_delete` - Auto-delete (exchange is deleted when last queue is unbound from it): [link](https://www.rabbitmq.com/tutorials/amqp-concepts.html#exchanges).
284
289
285
290
Default: `false`
286
291
287
292
### Queue auto delete
288
293
289
294
`queue_auto_delete`- Auto-delete (queue that has had at least one consumer is deleted when last consumer
0 commit comments