22
33namespace palPalani \SqsQueueReader \Sqs ;
44
5- use palPalani \ SqsQueueReader \Jobs \DispatcherJob ;
5+ use Illuminate \ Queue \Jobs \SqsJob ;
66use Illuminate \Queue \SqsQueue ;
77use Illuminate \Support \Facades \Config ;
8- use Illuminate \ Queue \Jobs \SqsJob ;
8+ use palPalani \ SqsQueueReader \Jobs \DispatcherJob ;
99
1010/**
1111 * Class CustomSqsQueue
@@ -23,7 +23,7 @@ class Queue extends SqsQueue
2323 */
2424 protected function createPayload ($ job , $ data = '' , $ queue = null )
2525 {
26- if (!$ job instanceof DispatcherJob) {
26+ if (! $ job instanceof DispatcherJob) {
2727 return parent ::createPayload ($ job , $ data , $ queue );
2828 }
2929
@@ -38,7 +38,7 @@ protected function createPayload($job, $data = '', $queue = null)
3838 */
3939 private function getClass ($ queue = null )
4040 {
41- if (!$ queue ) {
41+ if (! $ queue ) {
4242 return Config::get ('sqs-queue-reader.default-handler ' );
4343 }
4444
@@ -89,13 +89,15 @@ public function pop($queue = null)
8989 */
9090 private function modifyPayload ($ payload , $ class )
9191 {
92- if (! is_array ($ payload )) $ payload = json_decode ($ payload , true );
92+ if (! is_array ($ payload )) {
93+ $ payload = json_decode ($ payload , true );
94+ }
9395
9496 $ body = json_decode ($ payload ['Body ' ], true );
9597
9698 $ body = [
9799 'job ' => $ class . '@handle ' ,
98- 'data ' => isset ($ body ['data ' ]) ? $ body ['data ' ] : $ body
100+ 'data ' => isset ($ body ['data ' ]) ? $ body ['data ' ] : $ body,
99101 ];
100102
101103 $ payload ['Body ' ] = json_encode ($ body );
0 commit comments