fix: ackMessage

freyo · web-flow · commit 71e9b91fbdb5 · 2020-10-20T16:29:13.000+08:00
diff --git a/src/Queue/Jobs/RocketMQJob.php b/src/Queue/Jobs/RocketMQJob.php
@@ -118,7 +118,7 @@ public function delete()
 
         $this->connection
             ->getConsumer($this->getQueue())
-            ->ackMessage($this->message->getReceiptHandle());
+            ->ackMessage([$this->message->getReceiptHandle()]);
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -118,7 +118,7 @@ public function delete()`
`118`	`118`
`119`	`119`	`$this->connection`
`120`	`120`	`->getConsumer($this->getQueue())`
`121`		`- ->ackMessage($this->message->getReceiptHandle());`
	`121`	`+ ->ackMessage([$this->message->getReceiptHandle()]);`
`122`	`122`	`}`
`123`	`123`
`124`	`124`	`/**`