File tree Expand file tree Collapse file tree 1 file changed +15
-1
lines changed Expand file tree Collapse file tree 1 file changed +15
-1
lines changed Original file line number Diff line number Diff line change @@ -69,7 +69,7 @@ public function pop($queue = null)
6969 'MaxNumberOfMessages ' => 5 ,
7070 'MessageAttributeNames ' => ['All ' ],
7171 ]);
72-
72+
7373 if (isset ($ response ['Messages ' ]) && count ($ response ['Messages ' ]) > 0 ) {
7474 Log::debug ('Messages== ' , [$ response ['Messages ' ]]);
7575 $ queueId = explode ('/ ' , $ queue );
@@ -100,13 +100,27 @@ private function modifyPayload($payload, $class)
100100 $ payload = json_decode ($ payload , true );
101101 }
102102
103+ /*
103104 $body = json_decode($payload['Body'], true);
104105
105106 $body = [
106107 'job' => $class . '@handle',
107108 'data' => isset($body['data']) ? $body['data'] : $body,
108109 ];
109110
111+ $payload['Body'] = json_encode($body);
112+ */
113+
114+ $ body = [];
115+ foreach ($ payload as $ item ) {
116+ $ body [] = json_decode ($ item ['Body ' ], true );
117+ }
118+
119+ $ body = [
120+ 'job ' => $ class . '@handle ' ,
121+ 'data ' => $ body ,
122+ ];
123+
110124 $ payload ['Body ' ] = json_encode ($ body );
111125
112126 return $ payload ;
You can’t perform that action at this time.
0 commit comments