| @@ 69-77 (lines=9) @@ | ||
| 66 | * | |
| 67 | * @throws MessageReceiveException | |
| 68 | */ | |
| 69 | public function receiveAll(): array | |
| 70 |     { | |
| 71 | $messages = []; | |
| 72 |         while (null !== $message = $this->receive()) { | |
| 73 | $messages[] = $message; | |
| 74 | } | |
| 75 | ||
| 76 | return $messages; | |
| 77 | } | |
| 78 | } | |
| 79 | ||
| @@ 95-103 (lines=9) @@ | ||
| 92 | * | |
| 93 | * @throws MessageReceiveException | |
| 94 | */ | |
| 95 | public function receiveAll(): array | |
| 96 |     { | |
| 97 | $messages = []; | |
| 98 |         while (null !== $message = $this->receive()) { | |
| 99 | $messages[] = $message; | |
| 100 | } | |
| 101 | ||
| 102 | return $messages; | |
| 103 | } | |
| 104 | } | |
| 105 | ||