Skip to content

Commit 2b04156

Browse files
committed
fix mnsJob queue bug
1 parent 26da3ad commit 2b04156

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/Jobs/MnsJob.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ class MnsJob extends Job implements JobContract
4747
public function __construct(Container $container, MnsAdapter $mns, $queue, ReceiveMessageResponse $job)
4848
{
4949
$this->container = $container;
50-
$this->mns = $mns->useQueue($queue);
50+
$this->mns = $mns;
5151
$this->queue = $queue;
5252
$this->job = $job;
5353
}
@@ -69,7 +69,7 @@ public function delete()
6969
{
7070
try {
7171
$receiptHandle = $this->job->getReceiptHandle();
72-
$this->mns->deleteMessage($receiptHandle);
72+
$this->mns->useQueue($this->queue)->deleteMessage($receiptHandle);
7373
// 删除成功
7474
$this->deleted = true;
7575
} catch (MnsException $exception) {
@@ -92,7 +92,7 @@ public function release($delay = 0)
9292
$delay = $this->fromNowToNextVisibleTime($this->job->getNextVisibleTime());
9393
}
9494
parent::release($delay);
95-
$this->mns->changeMessageVisibility($this->job->getReceiptHandle(), $delay);
95+
$this->mns->useQueue($this->queue)->changeMessageVisibility($this->job->getReceiptHandle(), $delay);
9696
}
9797

9898
/**

0 commit comments

Comments
 (0)