Merge pull request #24 from Spriz/patch-1

Fallback if AWS doens't include MessageAttributes
lorenzo · Jun 18, 2018 · b9a35e9 · b9a35e9
2 parents 2b3f885 + 59c1588
commit b9a35e9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/Shell/Task/QueueWorkerTask.php b/src/Shell/Task/QueueWorkerTask.php
@@ -171,7 +171,8 @@ protected function _work($name, $job)
     {
         foreach ($job->get('Messages') as $message) {
             $data = json_decode($message['Body'], true);
-            $return = call_user_func($this->callbacks[$name], $data, $message['ReceiptHandle'], $message['MessageAttributes']);
+            $messageAttributes = isset($message['MessageAttributes']) ? $message['MessageAttributes'] : [];
+            $return = call_user_func($this->callbacks[$name], $data, $message['ReceiptHandle'], $messageAttributes);
             if ($return === true) {
                 $this->getSimpleQueue()->deleteMessage($name, $message['ReceiptHandle']);
             }