From 474ee7da2fb1d67e17e8392764d8c9b33fe558c9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=8D=E5=99=A8?= Date: Mon, 7 Jun 2021 10:14:43 +0800 Subject: [PATCH] update src/main/java/io/jboot/components/mq/aliyunmq/JbootAliyunmqImpl.java. --- .../java/io/jboot/components/mq/aliyunmq/JbootAliyunmqImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/io/jboot/components/mq/aliyunmq/JbootAliyunmqImpl.java b/src/main/java/io/jboot/components/mq/aliyunmq/JbootAliyunmqImpl.java index 10840621..d0df1a9a 100644 --- a/src/main/java/io/jboot/components/mq/aliyunmq/JbootAliyunmqImpl.java +++ b/src/main/java/io/jboot/components/mq/aliyunmq/JbootAliyunmqImpl.java @@ -111,7 +111,7 @@ public class JbootAliyunmqImpl extends JbootmqBase implements Jbootmq { properties.put(PropertyKeyConst.AccessKey, aliyunmqConfig.getAccessKey());//AccessKey 阿里云身份验证,在阿里云服务器管理控制台创建 properties.put(PropertyKeyConst.SecretKey, aliyunmqConfig.getSecretKey());//SecretKey 阿里云身份验证,在阿里云服务器管理控制台创建 properties.put(PropertyKeyConst.ProducerId, aliyunmqConfig.getProducerId());//您在控制台创建的Producer ID - properties.put(PropertyKeyConst.ONSAddr, aliyunmqConfig.getAddr()); + properties.put(PropertyKeyConst.NAMESRV_ADDR, aliyunmqConfig.getAddr()); properties.setProperty(PropertyKeyConst.SendMsgTimeoutMillis, aliyunmqConfig.getSendMsgTimeoutMillis());//设置发送超时时间,单位毫秒 return properties; } -- Gitee