gocommon/pkg/mq/rocketmq/consumer.go

package rocketmq

import (
	"git.shuncheng.lu/bigthing/gocommon/pkg/conf"
)

// Global 对象
var (
	_consumer *rocketMqConsumer
)

// 获取Consumer(Init后使用)
func GetConsumer() Consumer {
	//if _consumer == nil {
	//	return nil, errors.New("rocket-mq consumer not start, please boot init rocket-mq consumer")
	//}
	return _consumer
}

// 初始化
func InitConsumer() error {
	config, err := GetRocketMQConfig(ConsumerMQ, conf.MustValue)
	if err != nil {
		return err
	}
	initLogger(config)
	con, err := newConsumer(config.ToConsumerConfig()...)
	if err != nil {
		return err
	}
	_consumer = con
	return nil
}

// 启动
func StartConsumer() error {
	return _consumer.start()
}