go-template/business/job/rocket_mq_consumer.go

package job

import (
	"context"

	"gitea.ckfah.com/cjjy/gocommon/pkg/logger"

	"gitea.ckfah.com/cjjy/gocommon/pkg/mq/rocketmq"
	"github.com/apache/rocketmq-client-go/v2/primitive"
)

/**
开启 Rocket-MQ Consumer
*/
func StartRocketMQConsumer() error {
	if err := rocketmq.GetConsumer().Subscribe("test_topic", func(ctx context.Context, message *primitive.MessageExt) {
		logger.Infoc(ctx, "【消费者-1】trace_id: %s, 消息: %#v\n", rocketmq.GetMessageTraceId(message), message)
	}); err != nil {
		return err
	}
	return nil
}