| 12345678910111213141516171819202122232425262728293031 |
- package rocketmq
- import "git.shuncheng.lu/bigthing/gocommon/pkg/conf"
- // Global 对象
- var (
- _producer *rocketMqProducer
- )
- // 获取Consumer(程序启动后使用)
- func GetProducer() Producer {
- //if _producer == nil {
- // return nil, errors.New("rocket-mq producer is nil, please boot init rocket-mq producer")
- //}
- return _producer
- }
- // 初始化
- func InitProducer() error {
- config, err := GetRocketMQConfig(ProducerMQ, conf.MustValue)
- if err != nil {
- return err
- }
- initLogger(config)
- con, err := newProducer(config.ToProducerConfig()...)
- if err != nil {
- return err
- }
- _producer = con
- return nil
- }
|