Feature: #106261 - Align command line arguments of Message consumer with Symfony original
See forge#106261
Description
This change aligns the command line arguments of the TYPO3 Console
messenger: command with the original Symfony Messenger implementation.
The following new options have been added:
--/limit -l: Limit the number of received messages--/failure- limit -f: The number of failed messages the worker can consume--/memory- limit -m: The memory limit the worker can consume--/time- limit -t: The time limit in seconds the worker can handle new messages--/bus -b: Name of the bus to which received messages should be dispatched--: Consume messages from all receiversall --: Whether to use the transport's keepalive mechanism if implementedkeepalive
Scheduler Integration
The command can be configured as a scheduler task in TYPO3, enabling automated consumption of messages from the configured transports. This is particularly useful for processing asynchronous messages in the background.
This integration helps projects adopt asynchronous message handling by providing a reliable way to process messages without manual intervention. Messages can be dispatched asynchronously during regular request handling and consumed in the background by the scheduler task, improving application performance and user experience.
Important
The
messenger: command blocks other scheduler tasks from executing
while it is running. It is therefore strongly recommended to set the
-- option to a value lower than the scheduler's cron interval.
For example, if the scheduler runs every 5 minutes (300 seconds), set the time limit to 240 seconds (4 minutes) to ensure the task completes before the next scheduler run and allows other tasks to execute.
Usage
Consume messages from a specific receiver:
php vendor/bin/typo3 messenger:consume my_receiverConsume messages with a message limit:
php vendor/bin/typo3 messenger:consume my_receiver --limit=10Stop the worker after 2 failed messages:
php vendor/bin/typo3 messenger:consume my_receiver --failure-limit=2Stop the worker when memory limit is exceeded:
php vendor/bin/typo3 messenger:consume my_receiver --memory-limit=128MStop the worker after a time limit:
php vendor/bin/typo3 messenger:consume my_receiver --time-limit=3600Consume from specific queues only:
php vendor/bin/typo3 messenger:consume my_receiver --queues=fasttrackConsume from all configured receivers:
php vendor/bin/typo3 messenger:consume --all