| @@ 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 | ||