Example of usage conditional retry function for RabbitMQ

example.php

<?php
use PhpAmqpLib\Exception\AMQPIOException;
use PhpAmqpLib\Exception\AMQPProtocolException;
use PhpAmqpLib\Exception\AMQPRuntimeException;

retryConditional(
    function () use ($request, $readTimeout) : Response {
        return $this->doSend($request, $readTimeout); // sends message to RabbitMQ
    },
    function ($result, ?Throwable $ex) {
        if ($ex instanceof AMQPRuntimeException || $ex instanceof AMQPProtocolException || ($ex instanceof ErrorException && $ex->getMessage(
                ) === 'socket_write(): unable to write to socket [32]: Broken pipe') || ($ex instanceof AMQPIOException)) {
            pcntl_signal_dispatch();
            $this->logger->addWarning('Processing RabbitMQ reconnect due to: ' . $ex->getMessage());
            $this->reconnect();
            if (!$this->connection->isConnected()) {
                sleep(2); // Sleep for a while to prevent Rabbit reconnect DoS
            }
            return true;
        }
        return false;
    },
    30
);