fix mnsJob queue bug

milkmeowo · Jan 23, 2019 · 2b04156 · 2b04156
1 parent 26da3ad
commit 2b04156
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/Jobs/MnsJob.php b/src/Jobs/MnsJob.php
@@ -47,7 +47,7 @@ class MnsJob extends Job implements JobContract
     public function __construct(Container $container, MnsAdapter $mns, $queue, ReceiveMessageResponse $job)
     {
         $this->container = $container;
-        $this->mns = $mns->useQueue($queue);
+        $this->mns = $mns;
         $this->queue = $queue;
         $this->job = $job;
     }
@@ -69,7 +69,7 @@ public function delete()
     {
         try {
             $receiptHandle = $this->job->getReceiptHandle();
-            $this->mns->deleteMessage($receiptHandle);
+            $this->mns->useQueue($this->queue)->deleteMessage($receiptHandle);
             // 删除成功
             $this->deleted = true;
         } catch (MnsException $exception) {
@@ -92,7 +92,7 @@ public function release($delay = 0)
             $delay = $this->fromNowToNextVisibleTime($this->job->getNextVisibleTime());
         }
         parent::release($delay);
-        $this->mns->changeMessageVisibility($this->job->getReceiptHandle(), $delay);
+        $this->mns->useQueue($this->queue)->changeMessageVisibility($this->job->getReceiptHandle(), $delay);
     }
 
     /**