partnermarketing / queue
Partnermarketing's Queuing System
Installs: 368
Dependents: 0
Suggesters: 0
Security: 0
Stars: 0
Watchers: 1
Forks: 0
Open Issues: 0
pkg:composer/partnermarketing/queue
Requires
- ext-json: *
- predis/predis: ^1.1
Requires (Dev)
- phpunit/phpunit: ~9.0
This package is not auto-updated.
Last update: 2025-10-16 01:07:16 UTC
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.