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
91ea5d1fe8
commit
e942320040
1
pkg/common/storage/cache/redis/msg.go
vendored
1
pkg/common/storage/cache/redis/msg.go
vendored
@ -72,6 +72,7 @@ func (c *msgCache) SetMessagesToCache(ctx context.Context, conversationID string
|
|||||||
var values []string
|
var values []string
|
||||||
for _, key := range keys {
|
for _, key := range keys {
|
||||||
if msg, ok := msgMap[key]; ok {
|
if msg, ok := msgMap[key]; ok {
|
||||||
|
fmt.Print("rdb msgData is ", key, msg)
|
||||||
s, err := msgprocessor.Pb2String(msg)
|
s, err := msgprocessor.Pb2String(msg)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user