@@ -1038,9 +1038,9 @@ a running Redis server (^5.0).
1038
1038
A number of options can be configured via the DSN or via the ``options `` key
1039
1039
under the transport in ``messenger.yaml ``:
1040
1040
1041
- ================== ===================================== =========================
1042
- Option Description Default
1043
- ================== ===================================== =========================
1041
+ =================== ===================================== ======== =========================
1042
+ Option Description Default
1043
+ =================== ===================================== ======== =========================
1044
1044
stream The Redis stream name messages
1045
1045
group The Redis consumer group name symfony
1046
1046
consumer Consumer name used in Redis consumer
@@ -1056,7 +1056,23 @@ stream_max_entries The maximum number of entries which ``0`` (which means "n
1056
1056
it to a large enough number to
1057
1057
avoid losing pending messages
1058
1058
tls Enable TLS support for the connection false
1059
- ================== ===================================== =========================
1059
+ redeliver_timeout Timeout before retrying a pending ``3600 ``
1060
+ message which is owned by an
1061
+ abandoned consumer (if a worker died
1062
+ for some reason, this will occur,
1063
+ eventually you should retry the
1064
+ message) - in seconds.
1065
+ claim_interval Interval on which pending/abandoned ``60000 `` (1 Minute)
1066
+ messages should be checked for to
1067
+ claim - in milliseconds
1068
+ =================== ===================================== =================================
1069
+
1070
+ .. caution ::
1071
+
1072
+ There should never be more than one `messenger:consume ` command running with the same
1073
+ config (stream, group and consumer name) to avoid having a message handled more than once.
1074
+ Using the ``HOSTNAME `` as the consumer might often be a good idea. In case you are using
1075
+ Kubernetes to orchestrate your containers, consider using a ``StatefulSet ``.
1060
1076
1061
1077
.. tip ::
1062
1078
0 commit comments