| @@ 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 | ||
| @@ 12-20 (lines=9) @@ | ||
| 9 | * |
|
| 10 | * @throws MessageReceiveException |
|
| 11 | */ |
|
| 12 | public function receiveAll(): array |
|
| 13 | { |
|
| 14 | $messages = []; |
|
| 15 | while (null !== $message = $this->receive()) { |
|
| 16 | $messages[] = $message; |
|
| 17 | } |
|
| 18 | ||
| 19 | return $messages; |
|
| 20 | } |
|
| 21 | } |
|
| 22 | ||