@@ 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 | /** |
@@ 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 | ); |