aliyunmq

Documentation

Index

• Variables
• func GetProducer(name string) (producer rocketmq.Producer)
• func GetPushConsumer(name string) (consumer rocketmq.PushConsumer, err error)
• type ConsumeFunc
  • func NewConsumeFunc() ConsumeFunc
  • func (c *ConsumeFunc) Middleware(f func(msg *rocketmq.MessageExt) rocketmq.ConsumeStatus) func(msg *rocketmq.MessageExt) rocketmq.ConsumeStatus
  • func (c *ConsumeFunc) SetMaxCount(i int)
  • func (c *ConsumeFunc) SetTimeOut(i int)
• type Consumer
  • func NewConsumer(configName string) (consumer Consumer)
  • func (c Consumer) SetConsumerModel(consumerModel rocketmq.ConsumerModel)
  • func (c Consumer) SetMessageModel(messageModel rocketmq.MessageModel)
• type Producer
  • func NewProducer(configName string) (producer Producer)
  • func (p Producer) SetProducerModel(producerModel rocketmq.ProducerModel)
• type RocketMQConfig

Variables

var ConsumerList sync.Map

var ProducerList sync.Map

Functions

func GetProducer

func GetProducer(name string) (producer rocketmq.Producer)

func GetPushConsumer

func GetPushConsumer(name string) (consumer rocketmq.PushConsumer, err error)

Types

type ConsumeFunc

type ConsumeFunc struct {
	MaxCount int // 最大16次
	TimeOut  int // 超时时间
}

func NewConsumeFunc

func NewConsumeFunc() ConsumeFunc

func (*ConsumeFunc) Middleware

func (c *ConsumeFunc) Middleware(f func(msg *rocketmq.MessageExt) rocketmq.ConsumeStatus) func(msg *rocketmq.MessageExt) rocketmq.ConsumeStatus

最大重试次数，超过次数发邮件报警等功能可以直接扩展

func (*ConsumeFunc) SetMaxCount

func (c *ConsumeFunc) SetMaxCount(i int)

func (*ConsumeFunc) SetTimeOut

func (c *ConsumeFunc) SetTimeOut(i int)

type Consumer

type Consumer struct {
	RocketConf     RocketMQConfig
	ConsumerConfig *rocketmq.PushConsumerConfig
}

func NewConsumer

func NewConsumer(configName string) (consumer Consumer)

func (Consumer) SetConsumerModel

func (c Consumer) SetConsumerModel(consumerModel rocketmq.ConsumerModel)

func (Consumer) SetMessageModel

func (c Consumer) SetMessageModel(messageModel rocketmq.MessageModel)

type Producer

type Producer struct {
	RocketConf     RocketMQConfig
	ProducerConfig *rocketmq.ProducerConfig
}

func NewProducer

func NewProducer(configName string) (producer Producer)

func (Producer) SetProducerModel

func (p Producer) SetProducerModel(producerModel rocketmq.ProducerModel)

type RocketMQConfig

type RocketMQConfig struct {
	GroupID string
	// 设置 TCP 协议接入点，从阿里云 RocketMQ 控制台的实例详情页面获取。
	NameServer string
	// 您在阿里云账号管理控制台中创建的 AccessKeyId，用于身份认证。
	AccessKey string
	// 您在阿里云账号管理控制台中创建的 AccessKeySecret，用于身份认证。
	SecretKey string
	// 用户渠道，默认值为：ALIYUN。
	Channel string
}