rocketmq

type ConsumerConf struct {
	NsResolver            []string
	GroupName             string
	Namespace             string
	InstanceName          string
	Strategy              string
	RebalanceLockInterval int
	MaxReconsumeTimes     int32  // 1 means 16 times
	ConsumerModel         string // BroadCasting or Clustering or Unknown
	AutoCommit            bool
	Resolver              string
	AccessKey             string
	SecretKey             string
}

type ProducerConf struct {
	NsResolver                 []string // resolver address e.g. 127.0.0.1:9876
	GroupName                  string   `json:",optional"`
	Namespace                  string   `json:",optional"`
	InstanceName               string   `json:",optional"`
	MsgTimeOut                 int      `json:",optional"`
	DefaultTopicQueueNums      int      `json:",optional"`
	CreateTopicKey             string   `json:",optional"`
	CompressMsgBodyOverHowMuch int      `json:",optional"`
	CompressLevel              int      `json:",optional"`
	Retry                      int      `json:",optional"`
	AccessKey                  string   `json:",optional"`
	SecretKey                  string   `json:",optional"`
}