aliyunmq

Documentation

Index

• Variables
• func CloseProducer()
• func GetProducer(configName string) (conn rocketmq.Producer)
• func LogDebug()
• func LogError()
• func LogInfo()
• func LogWarn()
• func NewConsumer(configName, groupID string, option ...consumer.Option) rocketmq.PushConsumer
• func NewProducer(configName string, option ...producer.Option) rocketmq.Producer
• type RocketMQConfig

Variables

var ProducerPool sync.Map

Functions

func CloseProducer

func CloseProducer()

CloseProducer 关闭所有生产者而连接

func GetProducer

func GetProducer(configName string) (conn rocketmq.Producer)

GetProducer 获取生产者实例

func LogDebug

func LogDebug()

func LogError

func LogError()

func LogInfo

func LogInfo()

func LogWarn

func LogWarn()

func NewConsumer

func NewConsumer(configName, groupID string, option ...consumer.Option) rocketmq.PushConsumer

NewConsumer 初始化消费者

func NewProducer

func NewProducer(configName string, option ...producer.Option) rocketmq.Producer

NewProducer 初始化生产者

Types

type RocketMQConfig

type RocketMQConfig struct {
	// 设置 TCP 协议接入点，从阿里云 RocketMQ 控制台的实例详情页面获取。
	NameServer string
	// 命名空间（阿里云上的实例ID）
	Namespace string
	// 您在阿里云账号管理控制台中创建的 AccessKeyId，用于身份认证。
	AccessKey string
	// 您在阿里云账号管理控制台中创建的 AccessKeySecret，用于身份认证。
	SecretKey string
	// 是否自建RocketMQ true-自建 false-阿里云托管版。
	IsLocal bool
}

RocketMQConfig 基础配置