prooph/psb-enqueue-producer

Enqueue Message Producer for Prooph Service Bus

v0.5.0 2021-01-15 14:02 UTC

Requires

• php: ^7.1
• enqueue/simple-client: ^0.10
• prooph/common: ^4.1
• prooph/service-bus: ^6.0

Requires (Dev)

• enqueue/fs: ^0.10
• phpspec/prophecy: ^1.7
• phpunit/phpunit: ^6.0
• prooph/php-cs-fixer-config: ^0.4
• psr/container: ^1.0
• react/promise: ^2.4.1
• sandrokeil/interop-config: ^2.0.1

Suggests

• psr/container: ^1.0 for usage of provided factories
• sandrokeil/interop-config: For usage of provided factories

MIT

• Maksym Kotliar
• Alexander Miertsch
• Sascha-Oliver Prolic

• messaging
• cqrs
• enqueue
• prooph

README

Use Enqueue as a message producer for Prooph Service Bus.

Important

This library will receive support until December 31, 2019 and will then be deprecated.

For further information see the official announcement here: https://www.sasaprolic.com/2018/08/the-future-of-prooph-components.html

Installation

You can install the producer via composer by executing $ composer require prooph/psb-enqueue-producer.

Usage

Check the EnqueueMessageProducerTest. Set up the producer is a straightforward task. Most of the required components are provided by PSB and Enqueue. This package only provides the glue code needed to let both systems work together.

Why Enqueue producer

• You choose a transport from many supported ones.
• Could be used from Symfony as well as plain PHP.
• Supports delayed messages (if transport supports it).
• Supports events, commands and queues with possibility to get result.
• Simple and clean code.

Symfony configuration

If you're using the EnqueueBundle you can configure the classes from this package like this:

services:
    Prooph\ServiceBus\Message\Enqueue\EnqueueSerializer:
    Prooph\ServiceBus\Message\Enqueue\EnqueueMessageProducer:
        $commandName: 'my_application'
        $replyTimeout: 1000 # Timeout in milliseconds.
    Prooph\ServiceBus\Message\Enqueue\EnqueueMessageProcessor:
        tags:
            - { name: 'enqueue.processor', command: 'my_application' }
            # For enqueue 0.8 use this instead.
            #- { name: 'enqueue.client.processor', topicName: '__command__', processorName: 'my_application' }

Then you can run the processor like this:

bin/console enqueue:consume --setup-broker -vvv

See the Enqueue documentation for more information.

Support

• Ask questions on Stack Overflow tagged with #prooph.
• Ask enqueue questions in enqueue gitter chat.
• File issues at https://github.com/prooph/psb-enqueue-producer/issues.
• Say hello in the prooph gitter chat.

License

It is released under the MIT License.