add extra validate entries

enerBit · Oct 25, 2023 · 853e156 · 853e156
1 parent 634e9ff
commit 853e156
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/consumer/consumer.go b/pkg/consumer/consumer.go
@@ -101,7 +101,7 @@ func ConsumePendingOneByOne(ctx context.Context, client *redis.Client, groupName
 		return nil, err
 	}
 
-	if len(entries) > 0 {
+	if len(entries) > 0 && len(entries[0].Messages) > 0 {
 		return &entries[0].Messages[0], nil
 	}