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