|
6 | 6 | use Illuminate\Queue\Jobs\SqsJob; |
7 | 7 | use Illuminate\Queue\SqsQueue; |
8 | 8 | use Illuminate\Support\Facades\Config; |
9 | | -use Illuminate\Support\Facades\Log; |
10 | 9 | use Illuminate\Support\Str; |
11 | 10 | use palPalani\SqsQueueReader\Jobs\DispatcherJob; |
12 | 11 |
|
@@ -82,18 +81,15 @@ public function pop($queue = null) |
82 | 81 | ]); |
83 | 82 |
|
84 | 83 | if (isset($response['Messages']) && count($response['Messages']) > 0) { |
85 | | - Log::debug('Messages==', [$response['Messages']]); |
86 | 84 | $class = (array_key_exists($queueId, $this->container['config']->get('sqs-queue-reader.handlers'))) |
87 | 85 | ? $this->container['config']->get('sqs-queue-reader.handlers')[$queueId]['class'] |
88 | 86 | : $this->container['config']->get('sqs-queue-reader.default-handler')['class']; |
89 | 87 |
|
90 | | - Log::debug('Count, class==', [$count, $class]); |
91 | 88 | if ($count === 1) { |
92 | 89 | $response = $this->modifySinglePayload($response['Messages'][0], $class); |
93 | 90 | } else { |
94 | 91 | $response = $this->modifyMultiplePayload($response['Messages'], $class); |
95 | 92 | } |
96 | | - Log::debug('New $responseV2==', [$response]); |
97 | 93 |
|
98 | 94 | return new SqsJob($this->container, $this->sqs, $response, $this->connectionName, $queue); |
99 | 95 | } |
@@ -143,8 +139,6 @@ private function modifyMultiplePayload($payload, $class) |
143 | 139 | $attributes = []; |
144 | 140 |
|
145 | 141 | foreach ($payload as $k => $item) { |
146 | | - //Log::debug('Each Messages==', [$item]); |
147 | | - //$body[] = json_decode($item['Body'], true); |
148 | 142 | $body[$k] = [ |
149 | 143 | 'messages' => json_decode($item['Body'], true), |
150 | 144 | 'attributes' => $item['Attributes'], |
|
0 commit comments