@@ -628,17 +628,16 @@ times:
628
628
Change the ``async `` argument to use the name of your transport (or transports)
629
629
and ``user `` to the Unix user on your server.
630
630
631
- If you use the Redis Transport, note that each worker needs a unique consumer name to
632
- avoid the same message being handled by multiple workers. One way to achieve this is
633
- to set an environment variable in the Supervisor configuration file, which you can
634
- then refer to in `messenger.yaml ` (see Redis section above):
631
+ If you use the Redis Transport, note that each worker needs a unique consumer
632
+ name to avoid the same message being handled by multiple workers. One way to
633
+ achieve this is to set an environment variable in the Supervisor configuration
634
+ file, which you can then refer to in `` messenger.yaml ` ` (see Redis section above):
635
635
636
636
.. code-block :: ini
637
637
638
638
environment =MESSENGER_CONSUMER_NAME =%(program_name)s_%(process_num)02d
639
639
640
- Next, tell Supervisor to read your
641
- config and start your workers:
640
+ Next, tell Supervisor to read your config and start your workers:
642
641
643
642
.. code-block :: terminal
644
643
@@ -1251,9 +1250,9 @@ claim_interval Interval on which pending/abandoned ``60000`` (1 Minute)
1251
1250
1252
1251
There should never be more than one ``messenger:consume `` command running with the same
1253
1252
combination of ``stream ``, ``group `` and ``consumer ``, or messages could end up being
1254
- handled more than once. If you run multiple queue workers, ``consumer` can be set to an
1255
- environment variable (like ``%env(MESSENGER_CONSUMER_NAME)%`)` set by Supervisor
1256
- (example below) or whatever service used to manage the worker processes.
1253
+ handled more than once. If you run multiple queue workers, ``consumer `` can be set to an
1254
+ environment variable (like ``%env(MESSENGER_CONSUMER_NAME)% ``) set by Supervisor
1255
+ (example below) or any other service used to manage the worker processes.
1257
1256
In a container environment, the ``HOSTNAME `` can be used as the consumer name, since
1258
1257
there is only one worker per container/host. If using Kubernetes to orchestrate the
1259
1258
containers, consider using a ``StatefulSet `` to have stable names.
0 commit comments