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