fix queue bug

eclipse-symphony · Jan 23, 2025 · 03bdb49 · 03bdb49
1 parent 382b25a
commit 03bdb49
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/coa/pkg/apis/v1alpha2/providers/queue/redis/redisQueueProvider.go b/coa/pkg/apis/v1alpha2/providers/queue/redis/redisQueueProvider.go
@@ -268,9 +268,10 @@ func (rq *RedisQueueProvider) QueryByPaging(queueName string, start string, size
 	lastMessageID := ""
 	if len(xMessages) > size {
 		xMessages = xMessages[:size]
-		lastMessageID = xMessages[len(xMessages)-2].ID
+		lastMessageID = xMessages[len(xMessages)-1].ID
 	}
 	var results [][]byte
+
 	for _, xMsg := range xMessages {
 		jsonData := xMsg.Values["data"].(string)
 		results = append(results, []byte(jsonData))