package
1.1.11
Repository: https://github.com/github121380/golib.git
Documentation: pkg.go.dev

# Functions

No description provided by the author
NewMessage 创建一条新的消息.
RegisterWithConfig 根据提供的配置结构体注册RocketMQ服务并命名,后续可使用该名称调用服务.
Deprecated.
StartConsumer 启动指定已注册的RocketMQ消费服务, 同时指定要消费的消息标签,以及消费回调.
StartProducer 启动指定已注册的RocketMQ生产服务.
StopConsumer 停止指定已注册的RocketMQ消费服务.
StopProducer 停止指定已注册的RocketMQ生产服务.
No description provided by the author
No description provided by the author

# Constants

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Variables

ErrRmqSvcConfigInvalid 服务配置无效.
ErrRmqSvcInvalidOperation 当前操作无效.
ErrRmqSvcNotRegiestered 服务尚未被注册.

# Structs

ClientConfig 包含链接到RocketMQ服务所需要的各配置项.

# Interfaces

Message 消息提供的接口定义.

# Type aliases

DelayLevel 定义消息延迟发送的级别.
MessageCallback 定义业务方接收消息的回调接口.