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 10840621b3e2677baff12f6e0a192536520e1d93..d0df1a9ac19101dcaf9f4379324305b09e4eaf96 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; }