rocketmq

Documentation

Index

• func NewRocketMqBroker(conf *RocketMqConf) (broker.Broker, error)
• type RocketMqConf
  • func DefaultRocketMqConfig() *RocketMqConf

Functions

func NewRocketMqBroker

func NewRocketMqBroker(conf *RocketMqConf) (broker.Broker, error)

Types

type RocketMqConf

type RocketMqConf struct {
	Addrs             []string
	Retry             int
	MaxReconsumeTimes int32
	FromWhere         rocketmq.ConsumeFromWhere // mq的开始未知 0 最新位置  1 最早位置
	ConsumerMode      rocketmq.MessageModel     // 消费者模式 0 BroadCasting 1 Clustering
}

func DefaultRocketMqConfig

func DefaultRocketMqConfig() *RocketMqConf