Code Duplication    Length = 12-12 lines in 2 locations

src/ABS/Channel/PollableChannel.php 1 location

@@ 42-53 (lines=12) @@
39
    public function receive($timeout = -1)
40
    {
41
        $message = null;
42
        if ($timeout == 0) {
43
            $message = $this->getMessage();
44
        } elseif ($timeout < 0) {
45
            while (!$message = $this->getMessage()) {
46
            }
47
        } else {
48
            $time = time() + $timeout;
49
            while (($time > time()) && !$message = $this->getMessage()) {
50
            }
51
        }
52
53
        return $message;
54
    }
55
56
    /**

src/Channel/PollableChannel.php 1 location

@@ 58-69 (lines=12) @@
55
    {
56
        $this->doFireEvent(self::EVENT_PRE_RECEIVE);
57
        $message = null;
58
        if ($timeout == 0) {
59
            $message = $this->getMessage();
60
        } elseif ($timeout < 0) {
61
            while (!$message = $this->getMessage()) {
62
            }
63
        } else {
64
            $time = time() + $timeout;
65
            while (($time > time()) && !$message = $this->getMessage()) {
66
            }
67
        }
68
        $this->doFireEvent(
69
            self::EVENT_PRE_RECEIVE, [
70
                self::HEADER_MESSAGE => $message,
71
            ]
72
        );