Supporting Enqueue
Enqueue is an MIT-licensed open source project with its ongoing development made possible entirely by the support of community and our customers. If you’d like to join them, please consider:
Consumption extension
Here, I show how you can create a custom extension and register it. Let’s first create an extension itself:
<?php // src/AppBundle/Enqueue; namespace AppBundle\Enqueue; use Enqueue\Consumption\PostMessageReceivedExtensionInterface; use Enqueue\Consumption\Context\PostMessageReceived; class CountProcessedMessagesExtension implements PostMessageReceivedExtensionInterface { private $processedMessages = 0; public function onPostMessageReceived(PostMessageReceived $context): void { $this->processedMessages += 1; } } Now we have to register as a Symfony service with special tag:
services: app.enqueue.count_processed_messages_extension: class: 'AppBundle\Enqueue\CountProcessedMessagesExtension' tags: - { name: 'enqueue.consumption.extension', priority: 10 } When using multiple enqueue instances, you can apply extension to specific or all instances by providing an additional tag attribute:
services: app.enqueue.count_processed_messages_extension: class: 'AppBundle\Enqueue\CountProcessedMessagesExtension' tags: - { name: 'enqueue.consumption.extension', priority: 10, client: 'all' }