diff --git a/src/msg_transfer/logic/init.go b/src/msg_transfer/logic/init.go
index cd7f10106..03a7d2c33 100644
--- a/src/msg_transfer/logic/init.go
+++ b/src/msg_transfer/logic/init.go
@@ -20,6 +20,6 @@ func Init() {
 }
 func Run() {
 	//register mysqlConsumerHandler to
-	//go persistentCH.persistentConsumerGroup.RegisterHandleAndConsumer(&persistentCH)
+	go persistentCH.persistentConsumerGroup.RegisterHandleAndConsumer(&persistentCH)
 	go historyCH.historyConsumerGroup.RegisterHandleAndConsumer(&historyCH)
 }