rmqv2

Documentation

Overview

消息并发多条推送，但commit回复一次性回复，无法对单条消息进行commit回复，暂时不推荐使用 阿里云官方推荐使用 v1.2.4 版本

消息并发多条推送，但commit回复一次性回复，无法对单条消息进行commit回复，暂时不推荐使用 阿里云官方推荐使用 v1.2.4 版本

消息并发多条推送，但commit回复一次性回复，无法对单条消息进行commit回复，暂时不推荐使用 阿里云官方推荐使用 v1.2.4 版本

Index

• Constants
• type Consumer
  • func (c *Consumer) Subscribe(topic, expression string, ...) (err error)
• type ConsumerOption
  • func DefaultConsumerOption(consumerName string) (c *ConsumerOption)
  • func (c *ConsumerOption) MaxReconsumeTimes(maxcount int) *ConsumerOption
  • func (c *ConsumerOption) MessageModel(messageModel consumer.MessageModel) *ConsumerOption
  • func (c *ConsumerOption) Namespace(namespace string) *ConsumerOption
  • func (c *ConsumerOption) PullBatchSize(size int) *ConsumerOption
  • func (c *ConsumerOption) Start() (ps *Consumer, err error)
• type RocketMQConfig

Constants

const (
	ConsumerOPKeyGroupID           = "GroupName"
	ConsumerOPKeyNameServer        = "NameServer"
	ConsumerOPKeyCredentials       = "Credentials"
	ConsumerOPKeyMessageModel      = "MessageModel"
	ConsumerOPKeyNamespace         = "Namespace"
	ConsumerOPKeyMaxReconsumeTimes = "MaxReconsumeTimes"
	ConsumerOPKeyPullBatchSize     = "PullBatchSize"
)

Types

type Consumer

type Consumer struct {
	Consumer     rocketmq.PushConsumer
	ConsumerName string
	MaxCount     int // 最大次数，default = 16
	Timeout      int // 超时时间(单位：秒)，default = 60s
}

func (*Consumer) Subscribe

func (c *Consumer) Subscribe(topic, expression string, callback func(ctx context.Context, ext ...*primitive.MessageExt) error) (err error)

type ConsumerOption

type ConsumerOption struct {
	OpsMap map[string]consumer.Option
	// contains filtered or unexported fields
}

func DefaultConsumerOption

func DefaultConsumerOption(consumerName string) (c *ConsumerOption)

func (*ConsumerOption) MaxReconsumeTimes

func (c *ConsumerOption) MaxReconsumeTimes(maxcount int) *ConsumerOption

func (*ConsumerOption) MessageModel

func (c *ConsumerOption) MessageModel(messageModel consumer.MessageModel) *ConsumerOption

func (*ConsumerOption) Namespace

func (c *ConsumerOption) Namespace(namespace string) *ConsumerOption

func (*ConsumerOption) PullBatchSize

func (c *ConsumerOption) PullBatchSize(size int) *ConsumerOption

func (*ConsumerOption) Start

func (c *ConsumerOption) Start() (ps *Consumer, err error)

type RocketMQConfig

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