graze /
queue
| @@ 238-252 (lines=15) @@ | ||
| 235 | * |
|
| 236 | * @return array |
|
| 237 | */ |
|
| 238 | protected function createDeleteEntries(array $messages) |
|
| 239 | { |
|
| 240 | array_walk( |
|
| 241 | $messages, |
|
| 242 | function (MessageInterface &$message, $id) { |
|
| 243 | $metadata = $message->getMetadata(); |
|
| 244 | $message = [ |
|
| 245 | 'Id' => $id, |
|
| 246 | 'ReceiptHandle' => $metadata->get('ReceiptHandle'), |
|
| 247 | ]; |
|
| 248 | } |
|
| 249 | ); |
|
| 250 | ||
| 251 | return $messages; |
|
| 252 | } |
|
| 253 | ||
| 254 | /** |
|
| 255 | * @param MessageInterface[] $messages |
|
| @@ 259-274 (lines=16) @@ | ||
| 256 | * |
|
| 257 | * @return array |
|
| 258 | */ |
|
| 259 | protected function createRejectEntries(array $messages) |
|
| 260 | { |
|
| 261 | array_walk( |
|
| 262 | $messages, |
|
| 263 | function (MessageInterface &$message, $id) { |
|
| 264 | $metadata = $message->getMetadata(); |
|
| 265 | $message = [ |
|
| 266 | 'Id' => $id, |
|
| 267 | 'ReceiptHandle' => $metadata->get('ReceiptHandle'), |
|
| 268 | 'VisibilityTimeout' => 0, |
|
| 269 | ]; |
|
| 270 | } |
|
| 271 | ); |
|
| 272 | ||
| 273 | return $messages; |
|
| 274 | } |
|
| 275 | ||
| 276 | /** |
|
| 277 | * @param MessageInterface[] $messages |
|
