crutch / consumer
consumer interface
v1.0.0
2023-01-19 11:56 UTC
Requires
- php: ^7.4 || ^8.0
This package is not auto-updated.
Last update: 2024-11-22 00:22:37 UTC
README
Note that this is not a Consumer implementation of its own. It is merely abstractions that describe the components of a Consumer.
The installable package and implementations are listed on Packagist.
You may use \Crutch\Consumer\Consumers\RouteConsumer
for split consumers by topic
<?php /** @var Crutch\Consumer\Consumer $defaultConsumer */ /** @var Crutch\Consumer\Consumer $topicOneConsumer */ /** @var Crutch\Consumer\Consumer $topicTwoConsumer */ /** @var Crutch\Consumer\ConsumerHandler $handler */ $consumer = new Crutch\Consumer\Consumers\RouteConsumer($defaultConsumer); $consumer->setConsumer('one', $topicOneConsumer); $consumer->setConsumer('two', $topicTwoConsumer); $consumer->consume('one', $handler); // consumed by $topicOneConsumer $consumer->consume('two', $handler); // consumed by $topicTwoConsumer $consumer->consume('three', $handler); // consumed by $defaultConsumer
You may use \Crutch\Consumer\Handlers\RouteHandler
for split handlers by topic
<?php /** @var Crutch\Consumer\ConsumerHandler $defaultHandler */ /** @var Crutch\Consumer\ConsumerHandler $topicOneHandler */ /** @var Crutch\Consumer\ConsumerHandler $topicTwoHandler */ $handler = new Crutch\Consumer\Handlers\RouteHandler($defaultHandler); $handler->setHandler('one', $topicOneHandler); $handler->setHandler('two', $topicTwoHandler); $handler->handle('message 1', 'one'); // handled by $topicOneHandler $handler->handle('message 2', 'two'); // handled by $topicTwoHandler $handler->handle('message 3', 'three'); // handled by $defaultHandler