Merge pull request #11 from santi-giraldo2/fix

add extra validate entries
enerBit · Oct 25, 2023 · 0ff6df8 · 0ff6df8
2 parents 634e9ff + 853e156
commit 0ff6df8
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
 	}