rmqv1

type Consumer struct {
	// contains filtered or unexported fields
}

type ConsumerConfig struct {
	// 订阅 topic
	Topic string

	// expression
	Expression string

	// 最大次数，default = 16
	MaxCount int

	// 超时时间(单位：秒)，default = 60s
	Timeout int

	MessageModel rocketmq.MessageModel

	ConsumerModel rocketmq.ConsumerModel
}

type Producer struct {
	// contains filtered or unexported fields
}

type ProducerConfig struct {
	ProducerModel rocketmq.ProducerModel
}

type RocketMQ struct {
	// 配置文件对应的 MQ client
	ConfigName string
	// contains filtered or unexported fields
}