diff --git a/globalbackfeedmanager.go b/globalbackfeedmanager.go index d7d39f5..6c9f14e 100644 --- a/globalbackfeedmanager.go +++ b/globalbackfeedmanager.go @@ -281,6 +281,7 @@ func (that *GlobalBackfeedManager) HandleUnlink(res http.ResponseWriter, req *ht return } pipe := that.BackfeedRedis.Pipeline() + pipe.HDel(req.Context(), ":last_ts", keys...) for _, key := range keys { pipe.Unlink(req.Context(), key) }