Gelf\Transport\KeepAliveRetryTransportWrapper

Complexity

Total Complexity

5

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	send()	0	9	3
A	getTransport()	0	3	1

<?php

namespace Gelf\Transport;

use Gelf\MessageInterface as Message;

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

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

    /**
     * KeepAliveRetryTransportWrapper constructor.
     *
     * @param HttpTransport $transport
     */
    public function __construct(HttpTransport $transport)
    {
        $this->transport = $transport;
    }

    /**
     * @return HttpTransport
     */
    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)
    {
        try {
            return $this->transport->send($message);
        } catch (\RuntimeException $e) {
            if ($e->getMessage() !== self::NO_RESPONSE) {
                throw $e;
            }
            return $this->transport->send($message);
        }
    }
}