push update

3 years ago · 746b01f8ca
parent 657ec411c3
commit 746b01f8ca
1 changed files with 1 additions and 1 deletions
--- a/internal/msg_transfer/logic/online_history_msg_handler.go
+++ b/internal/msg_transfer/logic/online_history_msg_handler.go
@ -164,7 +164,7 @@ func (och *OnlineHistoryConsumerHandler) SendMessageToMongoCH(userID string, tri
 func (och *OnlineHistoryConsumerHandler) MongoMessageRun(channelID int) {
 	for {
 		select {
-		case cmd := <-och.chArrays[channelID]:
+		case cmd := <-och.chMongoArrays[channelID]:
 			switch cmd.Cmd {
 			case MongoMessages:
 				msgChannelValue := cmd.Value.(MsgChannelValue)