1414
1515/**
1616 * Class CustomSqsQueue
17- * @package App\Services
1817 */
1918class Queue extends SqsQueue
2019{
2120 /**
2221 * Create a payload string from the given job and data.
2322 *
24- * @param object|string $job
25- * @param string $queue
26- * @param mixed $data
23+ * @param object|string $job
24+ * @param string $queue
25+ * @param mixed $data
2726 * @return string
27+ *
2828 * @throws JsonException
2929 */
3030 protected function createPayload ($ job , $ queue = null , $ data = '' ): string
@@ -33,7 +33,7 @@ protected function createPayload($job, $queue = null, $data = ''): string
3333 return parent ::createPayload ($ job , $ queue , $ data );
3434 }
3535
36- $ handlerJob = $ this ->getClass ($ queue ) . '@handle ' ;
36+ $ handlerJob = $ this ->getClass ($ queue ). '@handle ' ;
3737
3838 return $ job ->isPlain () ? \json_encode ($ job ->getPayload (), JSON_THROW_ON_ERROR ) : \json_encode ([
3939 'job ' => $ handlerJob ,
@@ -62,8 +62,9 @@ private function getClass($queue = null): string
6262 /**
6363 * Pop the next job off of the queue.
6464 *
65- * @param string $queue
65+ * @param string $queue
6666 * @return \Illuminate\Contracts\Queue\Job|null
67+ *
6768 * @throws JsonException
6869 */
6970 public function pop ($ queue = null )
@@ -99,16 +100,17 @@ public function pop($queue = null)
99100 return new SqsJob ($ this ->container , $ this ->sqs , $ response , $ this ->connectionName , $ queue );
100101 }
101102 } catch (AwsException $ e ) {
102- $ msg = 'Line: ' . $ e ->getLine () .', ' . $ e ->getFile () . ', ' . $ e ->getMessage ();
103+ $ msg = 'Line: ' .$ e ->getLine ().', ' .$ e ->getFile (). ', ' .$ e ->getMessage ();
103104
104- throw new \RuntimeException (" Aws SQS error: " . $ msg );
105+ throw new \RuntimeException (' Aws SQS error: ' . $ msg );
105106 }
106107 }
107108
108109 /**
109- * @param array|string $payload
110- * @param string $class
110+ * @param array|string $payload
111+ * @param string $class
111112 * @return array|string
113+ *
112114 * @throws JsonException
113115 */
114116 private function modifySinglePayload (array | string $ payload , string $ class ): array | string
@@ -121,17 +123,18 @@ private function modifySinglePayload(array | string $payload, string $class): ar
121123
122124 $ payload ['Body ' ] = \json_encode ([
123125 'uuid ' => (string ) Str::uuid (),
124- 'job ' => $ class . '@handle ' ,
126+ 'job ' => $ class. '@handle ' ,
125127 'data ' => $ body ['data ' ] ?? $ body ,
126128 ], JSON_THROW_ON_ERROR );
127129
128130 return $ payload ;
129131 }
130132
131133 /**
132- * @param array|string $payload
133- * @param string $class
134+ * @param array|string $payload
135+ * @param string $class
134136 * @return array
137+ *
135138 * @throws JsonException
136139 */
137140 private function modifyMultiplePayload (array | string $ payload , string $ class ): array
@@ -170,18 +173,19 @@ private function modifyMultiplePayload(array | string $payload, string $class):
170173 'ReceiptHandle ' => $ receiptHandle ,
171174 'Body ' => \json_encode ([
172175 'uuid ' => (string ) Str::uuid (),
173- 'job ' => $ class . '@handle ' ,
176+ 'job ' => $ class. '@handle ' ,
174177 'data ' => $ body ,
175178 ], JSON_THROW_ON_ERROR ),
176179 'Attributes ' => $ attributes ,
177180 ];
178181 }
179182
180183 /**
181- * @param string $payload
182- * @param string|null $queue
183- * @param array $options
184+ * @param string $payload
185+ * @param string|null $queue
186+ * @param array $options
184187 * @return mixed
188+ *
185189 * @throws JsonException
186190 */
187191 public function pushRaw ($ payload , $ queue = null , array $ options = []): mixed
0 commit comments