adtechpotok/enqueue-messenger-adapter-bundle

Friday, July 27, 2018
by scarbo87
Repository
1 Watchers
0 Stars
25 Installations

PHP
0 Dependents
0 Suggesters
0 Forks
0 Open issues
12 Versions
0 % Grown

The README.md

Enqueue's transport for Symfony Messenger component

This Symfony Messenger transport allows you to use Enqueue to send and receive your messages from all the supported brokers., _(*1)

Usage

Install the transport

composer req enqueue/messenger-adapter

Configure the Enqueue bundle as you would normaly do (see Enqueue's Bundle documentation). If you are using the recipes, you should just have to configure the environment variables to configure the default Enqueue transport:

# .env
# ...

###> enqueue/enqueue-bundle ###
ENQUEUE_DSN=amqp://guest:guest@localhost:5672/%2f
###< enqueue/enqueue-bundle ###

Configure Messenger's transport (that we will name amqp) to use Enqueue's default transport:

# config/packages/messenger.yaml
framework:
    messenger:
        transports:
            amqp: enqueue://default

Route the messages that have to go through the message queue:

# config/packages/framework.yaml
framework:
    messenger:
        # ...

        routing:
            'App\Message\MyMessage': amqp

Consume!

bin/console messenger:consume-messages amqp

Advanced usage

Configure the queue(s) and exchange(s)

In the transport DSN, you can add extra configuration. Here is the reference DSN (note that the values are just for the example):, _(*2)

enqueue://default
    ?queue[routingKey][name]=queue_name
    &topic[name]=topic_name
    &topic[type]=topic|fanout|direct
    &deliveryDelay=1800
    &delayStrategy=Adtechpotok\Bundle\EnqueueMessengerAdapterBundle\Transport\RabbitMq375DelayPluginDelayStrategy
    &timeToLive=3600
    &receiveTimeout=1000
    &priority=1
    &maximumPriority=255
    &durability=1

# config/packages/messenger.yaml
framework:
    messenger:
        transports:
            events: enqueue://default?queue[*][name]=events&topic[name]=events&topic[type]=topic
            foo.events: enqueue://default?queue[foo][name]=foo.events&topic[name]=events&topic[type]=topic
            bar.events: enqueue://default?queue[bar][name]=bar.events&topic[name]=events&topic[type]=topic

        routing:
            App\Message\EventsMessage: events
            Foo\Message\EventsMessage: foo.events
            Bar\Message\EventsMessage: bar.events

Send a message on a specific topic

You can send a message on a specific topic using TransportConfiguration envelope item with your message:, _(*3)

use Enqueue\MessengerAdapter\EnvelopeItem\TransportConfiguration;

// ...

$this->bus->dispatch((new Envelope($message))->with(new TransportConfiguration(
    ['topic' => 'specific-topic']
)));

Message duplication preventing

This package provide deduplication mechanism based on Redis optimistic locking (there is documentation https://redis.io/topics/transactions "Optimistic locking using check-and-set"). It uses two dependencies which you have to implement by yourself., _(*4)

Configure UuidItemSetterMiddleware on produce bus. It will store UUID-4 identifier in envelope items.

# config/packages/messenger.yaml
framework:
    messenger:
        buses:
            messenger.produce:
                middleware:
                    - Adtechpotok\Bundle\EnqueueMessengerAdapterBundle\Middleware\UuidItemSetterMiddleware

Implement UniqueIdGetterInterface interface and register it as a service.

That interface will be used every time when LockBasedDeduplicationMiddleware will process a message. The method getUniqueId have to return a unique id each time when it will be called. LockBasedDeduplicationMiddleware will try to lock a message by this id. If it succeeds the message will be processed next otherwise you will get an exception., _(*5)

Example:, _(*6)

class IdGenerator implements UniqueIdGetterInterface
{
    /** @var string */
    protected $id;

    public function __construct()
    {
        $this->generateId();
    }

    /**
     * @return string
     */
    public function getUniqueId(): string
    {
        return $this->id;
    }

    public function generateId(): void
    {
        $this->id = uniqid('', true);
    }
}

#config/services.yaml
services:
    SystemBundle\Classes\IdGenerator:

system.middleware.service.locker:
    class: Adtechpotok\Bundle\EnqueueMessengerAdapterBundle\Service\RedisLockService
    arguments:
        - '@REDIS_CLIENT'
        - 'rabbit_mq_'
        - 172800
        - 'worker_id'

messenger.middleware.lock_based_deduplication:
    class: Adtechpotok\Bundle\EnqueueMessengerAdapterBundle\Middleware\LockBasedDeduplicationMiddleware
    arguments:
        - '@system.middleware.service.locker'
        - '@SystemBundle\Classes\IdGenerator'

Where @REDIS_CLIENT is your configured redis client., _(*7)

Configure LockBasedDeduplicationMiddleware

common:
    messenger:
        buses:
            messenger.consume:
                middleware:
                    - messenger.middleware.lock_based_deduplication

The Versions

27/07 2018

0.1.0

0.1.0.0

Sources Download

MIT

The Requires

The Development Requires

lookyman/phpstan-symfony dev-master

by Anton Sadovnikov

15/06 2018

0.1.1

0.1.1.0

Sources Download

MIT

The Requires

The Development Requires

lookyman/phpstan-symfony dev-master

symfony-bundle enqueue-messenger-adapter-bundle

adtechpotok/enqueue-messenger-adapter-bundle

The README.md

Enqueue's transport for Symfony Messenger component

Usage

Advanced usage

Configure the queue(s) and exchange(s)

Send a message on a specific topic

Message duplication preventing

The Versions

dev-feature/more-5452

The Requires

by Anton Sadovnikov

dev-master

The Requires

by Anton Sadovnikov

0.1.9

The Requires

by Anton Sadovnikov

0.1.8

The Requires

by Anton Sadovnikov

0.1.7

The Requires

by Anton Sadovnikov

0.1.6

The Requires

by Anton Sadovnikov

0.1.5

The Requires

by Anton Sadovnikov

0.1.4

The Requires

by Anton Sadovnikov

0.1.3

The Requires

by Anton Sadovnikov

0.1.2

The Requires

The Development Requires

by Anton Sadovnikov

0.1.0

The Requires

The Development Requires

by Anton Sadovnikov

0.1.1

The Requires

The Development Requires

by Anton Sadovnikov