检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
消息ID。 error_code String 错误码。 error_message String 错误信息。 请求示例 消费验证。 POST https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/messages/resend
String 任务ID。 请求示例 批量修改消费组的参数,将consumer-group-test消费组的最大重试次数修改为16。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups { "groups"
JAVA_HOME=/root/jdk1.8.0_231 export PATH=$JAVA_HOME/bin:$PATH 下载测试工具。 wget https://dist.apache.org/repos/dist/release/rocketmq/5.1.4/rocketmq-all-5.1
首尾字符不能为空格。 响应参数 无 请求示例 创建两个实例标签,标签名为key1、key2,值为value1、value2。 POST https://{endpoint}/v2/{project_id}/rocketmq/{instance_id}/tags/action {
将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。 find / -name librocketmq.so 将librocketmq.so添加到系统动态库搜索路径。 ln -s /查找到的librocketmq.so路径/librocketmq
Service) 云审计为您提供云服务资源的操作记录,记录内容包括您从华为云管理控制台或者开放API发起的云服务资源操作请求以及每次请求的结果,供您查询、审计和回溯使用。 弹性云服务器(Elastic Cloud Server) 弹性云服务器是由CPU、内存、操作系统、云硬盘组成的基础的计
name String 属性名称。 value String 属性值。 请求示例 导出主题中指定消息ID和Key的死信消息。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/messages/export
com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy 发送定时消息 发送定时消息的示例代码如下(以下
将librocketmq.so添加到系统动态库搜索路径。 查找librocketmq.so的路径。 find / -name librocketmq.so 将librocketmq.so添加到系统动态库搜索路径。 ln -s /查找到的librocketmq.so路径/librocketmq
com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy 发送顺序消息 参考如下示例代码(以下加粗内容需
com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy 发送事务消息 参考如下示例代码(以下加粗内容需
消费组名称。 perm String 权限。 请求示例 创建一个非管理员的用户,授予发布、订阅topic1和group1的权限。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/users { "access_key"
perm String 权限。 请求示例 修改用户参数,授予user_name用户发布、订阅topic1和group1的权限。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/users/{user_name}
com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy 同步发送 同步发送是指消息发送方发出一条消息到
一业务单元的消息,可以根据不同业务目的在同一Topic下设置不同的标签。标签能够有效保持代码的清晰度和连贯性,并优化RocketMQ提供的查询系统。消费者可以根据Tag实现对不同Topic的不同消费逻辑,实现更好的扩展性。 Topic是消息的一级分类,Tag是消息的二级分类,关系如下图。
(MessageExt messageExt) { System.out.println("收到回查,重新查询事务状态: " + messageExt); return LocalTransactionState.COMMIT_MESSAGE;