partnermarketing/queue

Partnermarketing's Queuing System

v1.1.1 2021-04-22 21:24 UTC

Requires

• ext-json: *
• predis/predis: ^1.1

Requires (Dev)

• phpunit/phpunit: ~9.0

Apache-2.0

README

This is a PHP implementation of the Redis message passing / queuing system we are using for Partnermarketing.

To send events to a Stream, use the EventPublisher.

To handle events coming in on Streams, you should implement the QueueListener interface (possibly by extending AbstractQueueListener and register it with the ListenerHandler.

To load / request Entity values, use the EntityConsumer and to act as a service that generates Entity values, you need to handle requests by implemtenting a listener on its stream, and save those back to Redis with the EntityProvider.