NotificationsYou must be signed in to change notification settings
Fork9.6k
Star30.4k

[Messenger] Add BatchAsyncHandlerTrait for ParallelMessageBus#60080

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to ourterms of service andprivacy statement. We’ll occasionally send you account related emails.

Already on GitHub?Sign in to your account

Jump to bottom

Open

matyo91 wants to merge2 commits intosymfony:7.4

base:7.4

Choose a base branch

frommatyo91:messenger-handling-concurrent-messages

Open

[Messenger] Add BatchAsyncHandlerTrait for ParallelMessageBus#60080

matyo91 wants to merge2 commits intosymfony:7.4frommatyo91:messenger-handling-concurrent-messages

Conversation

Copy link

Contributor

matyo91 commentedMar 28, 2025

Q	A
Branch?	7.3
Bug fix?	no
New feature?	yes
Deprecations?	no
Issues	Fix#53964 (comment)
License	MIT

Key Features

This implementation enables efficient batch processing while taking advantage of the parallel execution capabilities of ParallelMessageBus.

Usage Example

Here's how you would use this trait in a handler class:

class MyParallelBatchHandler{use BatchAsyncHandlerTrait;publicfunction__construct(ParallelMessageBus$parallelBus)    {$this->setParallelMessageBus($parallelBus);    }publicfunction__invoke(MyMessage$message)    {return$this->handle($message,null);    }privatefunctionprocess(array$jobs):void    {// This is the fallback implementation that will only be used// if ParallelMessageBus is not available/set// Extract message data$data =array_map(fn($job) =>$job[0]->getData(),$jobs);// Perform batch processing// ...// Acknowledge all messagesforeach ($jobsas [$message,$ack]) {$ack->ack();        }    }}