From 651c904affa1708d7dfefe4c7193f319708d79c5 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Wed, 10 May 2023 18:03:21 +0800 Subject: [PATCH] mongo --- pkg/common/db/controller/common_msg.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/common/db/controller/common_msg.go b/pkg/common/db/controller/common_msg.go index aafe51a85..da4d785cb 100644 --- a/pkg/common/db/controller/common_msg.go +++ b/pkg/common/db/controller/common_msg.go @@ -133,7 +133,7 @@ func (db *commonMsgDatabase) MsgToPushMQ(ctx context.Context, conversationID str func (db *commonMsgDatabase) MsgToMongoMQ(ctx context.Context, conversationID string, messages []*sdkws.MsgData, lastSeq int64) error { if len(messages) > 0 { - _, _, err := db.producerToModify.SendMessage(ctx, conversationID, &pbMsg.MsgDataToMongoByMQ{LastSeq: lastSeq, ConversationID: conversationID, MsgData: messages}) + _, _, err := db.producerToMongo.SendMessage(ctx, conversationID, &pbMsg.MsgDataToMongoByMQ{LastSeq: lastSeq, ConversationID: conversationID, MsgData: messages}) return err } return nil