redis msg cache

openimsdk · Dec 26, 2024 · 9a009a6 · 9a009a6
1 parent ca8d551
commit 9a009a6
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/pkg/common/storage/controller/msg_transfer.go b/pkg/common/storage/controller/msg_transfer.go
@@ -251,9 +251,6 @@ func (db *msgTransferDatabase) BatchInsertChat2Cache(ctx context.Context, conver
 		userSeqMap[m.SendID] = m.Seq
 		seqs = append(seqs, m.Seq)
 	}
-	if err := db.msgCache.DelMessageBySeqs(ctx, conversationID, seqs); err != nil {
-		return 0, false, nil, err
-	}
 	if err := db.msgCache.SetMessageBySeqs(ctx, conversationID, datautil.Slice(msgs, convert.MsgPb2DB)); err != nil {
 		return 0, false, nil, err
 	}