rmqtool

type ConsumerConfig struct {
	Topic        string
	Tag          string
	Group        string // consumer group
	Order        bool   // fifo message
	ConsumerMode ConsumerMode
	MsgHandler   func(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error)
}

type ConsumerMode int

type Rmq struct {
	Producer *rocketmq.Producer
}

type RmqConfig struct {
	NameServers []string
}

type RmqMsg struct {
	Topic string
	Tag   string
	Keys  []string
	Body  []byte
}