prooph / psb-enqueue-producer
Enqueue Message Producer for Prooph Service Bus
Installs: 95 226
Dependents: 0
Suggesters: 0
Security: 0
Stars: 10
Watchers: 7
Forks: 8
Open Issues: 1
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
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.