2017 © Pedro Peláez
 

library psb-enqueue-producer

Enqueue Message Producer for Prooph Service Bus

image

prooph/psb-enqueue-producer

Enqueue Message Producer for Prooph Service Bus

  • Sunday, December 17, 2017
  • by prooph
  • Repository
  • 5 Watchers
  • 6 Stars
  • 789 Installations
  • PHP
  • 0 Dependents
  • 0 Suggesters
  • 0 Forks
  • 0 Open issues
  • 5 Versions
  • 112 % Grown

The README.md

Enqueue Message Producer for Prooph Service Bus

Use Enqueue as a message producer for Prooph Service Bus., (*1)

Important

This library will receive support until December 31, 2019 and will then be deprecated., (*2)

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

Installation

You can install the producer via composer by executing $ composer require prooph/psb-enqueue-producer., (*4)

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., (*5)

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:, (*6)

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:, (*7)

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

See the Enqueue documentation for more information., (*8)

Support

License

It is released under the MIT License., (*9)

The Versions