Repository files navigation

UseEnqueue as a message producer forProoph Service Bus.

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

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

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

• You choose a transport frommany 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.

If you're using theEnqueueBundle 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 theEnqueue documentation for more information.

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

It is released under theMIT License.