99use Illuminate \Queue \SqsQueue ;
1010use Illuminate \Support \Facades \Config ;
1111use Illuminate \Support \Str ;
12+ use JsonException ;
1213use palPalani \SqsQueueReader \Jobs \DispatcherJob ;
1314
1415/**
@@ -24,7 +25,7 @@ class Queue extends SqsQueue
2425 * @param string $queue
2526 * @param mixed $data
2627 * @return string
27- * @throws \ JsonException
28+ * @throws JsonException
2829 */
2930 protected function createPayload ($ job , $ queue = null , $ data = '' ): string
3031 {
@@ -104,12 +105,12 @@ public function pop($queue = null)
104105 }
105106
106107 /**
107- * @param string| array $payload
108+ * @param array|string $payload
108109 * @param string $class
109- * @return array
110- * @throws \ JsonException
110+ * @return array|string
111+ * @throws JsonException
111112 */
112- private function modifySinglePayload ($ payload , $ class )
113+ private function modifySinglePayload (array | string $ payload , string $ class ): array | string
113114 {
114115 if (! is_array ($ payload )) {
115116 $ payload = \json_decode ($ payload , true , 512 , JSON_THROW_ON_ERROR );
@@ -129,19 +130,21 @@ private function modifySinglePayload($payload, $class)
129130 }
130131
131132 /**
132- * @param string| array $payload
133+ * @param array|string $payload
133134 * @param string $class
134135 * @return array
135- * @throws \ JsonException
136+ * @throws JsonException
136137 */
137- private function modifyMultiplePayload ($ payload , $ class )
138+ private function modifyMultiplePayload (array | string $ payload , string $ class ): array
138139 {
139140 if (! is_array ($ payload )) {
140141 $ payload = \json_decode ($ payload , true , 512 , JSON_THROW_ON_ERROR );
141142 }
142143
143144 $ body = [];
144145 $ attributes = [];
146+ $ messageId = null ;
147+ $ receiptHandle = null ;
145148
146149 foreach ($ payload as $ k => $ item ) {
147150 $ body [$ k ] = [
@@ -173,12 +176,12 @@ private function modifyMultiplePayload($payload, $class)
173176
174177 /**
175178 * @param string $payload
176- * @param null|string $queue
179+ * @param null $queue
177180 * @param array $options
178- * @return mixed|null
179- * @throws \ JsonException
181+ * @return mixed
182+ * @throws JsonException
180183 */
181- public function pushRaw ($ payload , $ queue = null , array $ options = [])
184+ public function pushRaw ($ payload , $ queue = null , array $ options = []): mixed
182185 {
183186 $ payload = \json_decode ($ payload , true , 512 , JSON_THROW_ON_ERROR );
184187
0 commit comments