Gelf\Transport\RetryTransportWrapper

Complexity

Total Complexity

9

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
B	send()	0	15	7
A	getTransport()	0	3	1

<?php

namespace Gelf\Transport;

use Gelf\MessageInterface as Message;
use RuntimeException;

class RetryTransportWrapper extends AbstractTransport
{
    /**
     * @const string
     */
    const NO_RESPONSE = "Graylog-Server didn't answer properly, expected 'HTTP/1.x 202 Accepted', response is ''";

    /**
     * @var TransportInterface
     */
    protected $transport;

    /**
     * @var int
     */
    protected $maxRetries;

    /**
     * @var callable|null
     */
    protected $exceptionMatcher;

    /**
     * KeepAliveRetryTransportWrapper constructor.
     *
     * @param TransportInterface $transport
     * @param int $maxRetries
     * @param callable|null $exceptionMatcher
     */
    public function __construct(TransportInterface $transport, $maxRetries, $exceptionMatcher = null)
    {
        $this->transport = $transport;
        $this->maxRetries = $maxRetries;
        $this->exceptionMatcher = $exceptionMatcher;
    }

    /**
     * @return TransportInterface
     */
    public function getTransport()
    {
        return $this->transport;
    }

    /**
     * Sends a Message over this transport.
     *
     * @param Message $message
     *
     * @return int calls function to send message
     */
    public function send(Message $message)
    {
        $tries = 0;

        while (true) {
            try {
                $tries++;
                return $this->transport->send($message);
            } catch (RuntimeException $e) {
                if ($this->maxRetries !== 0 && $tries > $this->maxRetries) {
                    throw $e;
                }

                if ($this->exceptionMatcher && !call_user_func($this->exceptionMatcher, $e)) {
                    throw $e;
                }
            }
        }
    }
}