Versions in this module Expand all Collapse all v1 v1.3.3 Jan 24, 2024 Changes in this version + type ConsumerConf struct + AccessKey string + AutoCommit bool + ConsumerModel string + GroupName string + InstanceName string + MaxReconsumeTimes int32 + Namespace string + NsResolver []string + RebalanceLockInterval int + Resolver string + SecretKey string + Strategy string + func (c *ConsumerConf) MustNewPullConsumer() *rocketmq.PullConsumer + func (c *ConsumerConf) MustNewPushConsumer() *rocketmq.PushConsumer + func (c *ConsumerConf) Validate() error + type ProducerConf struct + AccessKey string + CompressLevel int + CompressMsgBodyOverHowMuch int + CreateTopicKey string + DefaultTopicQueueNums int + GroupName string + InstanceName string + MsgTimeOut int + Namespace string + NsResolver []string + Retry int + SecretKey string + func (c *ProducerConf) MustNewProducer() *rocketmq.Producer + func (c *ProducerConf) Validate() error
Go to main page