get seqs

2 years ago · 2358ec3d90
parent 8a8cd8655a
commit 2358ec3d90
1 changed files with 4 additions and 1 deletions
--- a/pkg/common/db/cache/msg.go
+++ b/pkg/common/db/cache/msg.go
@ -137,7 +137,10 @@ func (c *msgCache) getSeqs(ctx context.Context, items []string, getkey func(s st
 		if seq.Err() != nil && seq.Err() != redis.Nil {
 			return nil, errs.Wrap(v.Err())
 		}
-		m[items[i]] = utils.StringToInt64(seq.Val())
+		seqInt64 := utils.StringToInt64(seq.Val())
+		if seqInt64 != 0 {
+			m[items[i]] = seqInt64
+		}
 	}
 	return m, nil
 }