rocketmq

Documentation

Index

• type ConsumerConf
  • func (c *ConsumerConf) MustNewPullConsumer() *rocketmq.PullConsumer
  • func (c *ConsumerConf) MustNewPushConsumer() *rocketmq.PushConsumer
  • func (c *ConsumerConf) Validate() error
• type ProducerConf
  • func (c *ProducerConf) MustNewProducer() *rocketmq.Producer
  • func (c *ProducerConf) Validate() error

Types

type ConsumerConf

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
}

ConsumerConf is the configuration of rocketmq consumer.

func (*ConsumerConf) MustNewPullConsumer

func (c *ConsumerConf) MustNewPullConsumer() *rocketmq.PullConsumer

MustNewPullConsumer returns a pull consumer. If there are errors, it will exist.

func (*ConsumerConf) MustNewPushConsumer

func (c *ConsumerConf) MustNewPushConsumer() *rocketmq.PushConsumer

MustNewPushConsumer returns a push consumer. If there are errors, it will exist.

func (*ConsumerConf) Validate

func (c *ConsumerConf) Validate() error

Validate validates configurations.

type ProducerConf

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"`
}

ProducerConf is the configuration of rocketmq producer.

func (*ProducerConf) MustNewProducer

func (c *ProducerConf) MustNewProducer() *rocketmq.Producer

MustNewProducer returns a producer. If there are errors, it will exist.

func (*ProducerConf) Validate

func (c *ProducerConf) Validate() error

Validate the configuration If the configuration is not set, change it into default