package logic import ( "Open_IM/pkg/common/config" "Open_IM/pkg/common/kafka" "fmt" ) var ( persistentCH PersistentConsumerHandler historyCH HistoryConsumerHandler producer *kafka.Producer ) func Init() { persistentCH.Init() historyCH.Init() producer = kafka.NewKafkaProducer(config.Config.Kafka.Ms2pschat.Addr, config.Config.Kafka.Ms2pschat.Topic) } func Run() { //register mysqlConsumerHandler to if config.Config.ChatPersistenceMysql { go persistentCH.persistentConsumerGroup.RegisterHandleAndConsumer(&persistentCH) } else { fmt.Println("not start mysql consumer") } go historyCH.historyConsumerGroup.RegisterHandleAndConsumer(&historyCH) }