Merge pull request #24 from Spriz/patch-1

lorenzo · web-flow · commit b9a35e91fa42 · 2018-06-18T16:17:40.000+02:00
Fallback if AWS doens't include MessageAttributes
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']);
             }

Original file line number	Diff line number	Diff line change
`@@ -171,7 +171,8 @@ protected function _work($name, $job)`
`171`	`171`	`{`
`172`	`172`	`foreach ($job->get('Messages') as $message) {`
`173`	`173`	`$data = json_decode($message['Body'], true);`
`174`		`- $return = call_user_func($this->callbacks[$name], $data, $message['ReceiptHandle'], $message['MessageAttributes']);`
	`174`	`+ $messageAttributes = isset($message['MessageAttributes']) ? $message['MessageAttributes'] : [];`
	`175`	`+ $return = call_user_func($this->callbacks[$name], $data, $message['ReceiptHandle'], $messageAttributes);`
`175`	`176`	`if ($return === true) {`
`176`	`177`	`$this->getSimpleQueue()->deleteMessage($name, $message['ReceiptHandle']);`
`177`	`178`	`}`