From 0e32ced94b5919f82876386477fbdda983a16895 Mon Sep 17 00:00:00 2001
From: timeless <zyg1762608842>
Date: Mon, 24 Nov 2025 09:45:42 +0800
Subject: [PATCH] fix MessageQueueMethod::claim

---
 src/Builders/Traits/MessageQueueMethod.php | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/Builders/Traits/MessageQueueMethod.php b/src/Builders/Traits/MessageQueueMethod.php
index 79df0ec..d37f639 100644
--- a/src/Builders/Traits/MessageQueueMethod.php
+++ b/src/Builders/Traits/MessageQueueMethod.php
@@ -348,8 +348,8 @@ public function claim(Worker $worker, int $pendingTimeout, bool $autoDel = true)
                 );
                 if ($datas) {
                     $this->claimStartTags[$queueName][$groupName][$consumerName] = $datas[0] ?? '0-0';
-                    if ($datas = $datas[2] ?? []) {
-                        if ($client->xAck($queueName, $groupName, $datas)) {
+                    if ($datas = $datas[1] ?? []) {
+                        if ($client->xAck($queueName, $groupName, array_keys($datas))) {
                             // pending超时的消息自动ack，并存入本地缓存
                             try {
                                 foreach ($datas as $message) {