crutch/consumer

consumer interface

v1.0.0 2023-01-19 11:56 UTC

Requires

• php: ^7.4 || ^8.0

MIT

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