@@ -628,17 +628,16 @@ times:
628628 Change the ``async `` argument to use the name of your transport (or transports)
629629and ``user `` to the Unix user on your server.
630630
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):
635635
636636.. code-block :: ini
637637
638638 environment =MESSENGER_CONSUMER_NAME =%(program_name)s_%(process_num)02d
639639
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:
642641
643642.. code-block :: terminal
644643
@@ -1251,9 +1250,9 @@ claim_interval Interval on which pending/abandoned ``60000`` (1 Minute)
12511250
12521251 There should never be more than one ``messenger:consume `` command running with the same
12531252 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.
12571256 In a container environment, the ``HOSTNAME `` can be used as the consumer name, since
12581257 there is only one worker per container/host. If using Kubernetes to orchestrate the
12591258 containers, consider using a ``StatefulSet `` to have stable names.
0 commit comments