diff --git a/internal/msg_transfer/logic/online_history_msg_handler.go b/internal/msg_transfer/logic/online_history_msg_handler.go
index b6919554d..5c34b8ff4 100644
--- 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)