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) {