You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
26 lines
571 B
26 lines
571 B
1 year ago
|
package logic
|
||
|
|
|
||
|
|
import (
|
||
|
|
"Open_IM/pkg/common/config"
|
||
|
|
|
||
|
|
"Open_IM/pkg/common/kafka"
|
||
|
|
)
|
||
|
|
|
||
|
|
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
|
||
|
|
go persistentCH.persistentConsumerGroup.RegisterHandleAndConsumer(&persistentCH)
|
||
|
|
go historyCH.historyConsumerGroup.RegisterHandleAndConsumer(&historyCH)
|
||
|
|
}
|