Link Search Menu Expand Document

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:

Client extensions.

There is an ability to hook into sending process. You have to create an extension class that implements Enqueue\Client\ExtensionInterface interface. For example, TimestampMessageExtension extension adds timestamps every message before sending it to MQ.

namespace Acme;

use Enqueue\Client\ExtensionInterface;
use Enqueue\Client\Message;

class TimestampMessageExtension implements ExtensionInterface
    public function onPreSend($topic, Message $message)
        if ($message->getTimestamp()) {

    public function onPostSend($topic, Message $message)



To use the extension in Symfony, you have to register it as a container service with a special tag.

# config/services.yaml

    class: Acme\TimestampMessageExtension
      - { name: 'enqueue.client.extension' }

You can add priority attribute with a number. The higher value you set the earlier the extension is called.

back to index