mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-11-05 03:42:08 +08:00
refactor: delete message and message batch use lua.
This commit is contained in:
parent
b3ee2d9edb
commit
1dffc3f0eb
1
pkg/common/storage/cache/redis/msg.go
vendored
1
pkg/common/storage/cache/redis/msg.go
vendored
@ -172,6 +172,7 @@ func (c *msgCache) GetMessagesBySeq(ctx context.Context, conversationID string,
|
|||||||
|
|
||||||
msg := &sdkws.MsgData{}
|
msg := &sdkws.MsgData{}
|
||||||
msgString, ok := value.(string)
|
msgString, ok := value.(string)
|
||||||
|
fmt.Sprintf("get result", "seq", seq, "msg string", msgString)
|
||||||
if !ok || msgprocessor.String2Pb(msgString, msg) != nil {
|
if !ok || msgprocessor.String2Pb(msgString, msg) != nil {
|
||||||
failedSeqs = append(failedSeqs, seq)
|
failedSeqs = append(failedSeqs, seq)
|
||||||
continue
|
continue
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user