crutch/consumer-handler-retry

consumer retry handler

Maintainers

Details

github.com/php-crutch/consumer-handler-retry

Source

Issues

Installs: 32

Dependents: 0

Suggesters: 0

Security: 0

Stars: 0

Watchers: 0

Forks: 0

Open Issues: 0

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

Requires

Provides

MIT 5a0a6b1eb7ed0c31881e84b885b1d8881b70bc9e

This package is not auto-updated.

Last update: 2024-11-22 03:34:22 UTC

README

consumer handler for retrying failed messages

Install

composer require crutch/consumer-handler-retry
<?php

/** @var Crutch\Producer\Producer $retryProducer */
/** @var Crutch\Consumer\ConsumerHandler $handler */
/** @var null|Crutch\RetryConsumerHandler\TopicStrategy\TopicStrategy $topicStrategy */
/** @var null|Crutch\RetryConsumerHandler\DelayStrategy\DelayStrategy $delayStrategy */
/** @var null|int $maxAttempts */

$retryHandler = new Crutch\RetryConsumerHandler\RetryConsumerHandler(
    $handler,
    $retryProducer,
    $topicStrategy,
    $delayStrategy,
    $maxAttempts
);

/**
 * if $handler throws exception, $retryProducer produced message to topic, defined by $topicStrategy 
 * with delay, calculated by $selayStrategy.
 */
$retryHandler->handle('message 1', 'one'); // handled by $topicOneHandler