jiulinxiri/rocketmq-dashboard
1
0
Fork 0
mirror of https://github.com/apache/rocketmq-dashboard.git synced 2025-09-10 11:40:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

support set accessKey,secretKey params from properties or env

Browse Source
This commit is contained in:
sunyuchao
2023-11-29 15:41:10 +08:00
parent 6456630324
commit 77cc8a3ffa
1 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/org/apache/rocketmq/dashboard/config/RMQConfigure.java
View File

@@ -38,6 +38,8 @@ import static org.apache.rocketmq.client.ClientConfig.SEND_MESSAGE_WITH_VIP_CHAN
@Configuration
@ConfigurationProperties(prefix = "rocketmq.config")
public class RMQConfigure {
private static final String ROCKET_MQ_AK_PROPERTY = "rocketmq.config.accessKey";
private static final String ROCKET_MQ_SK_PROPERTY = "rocketmq.config.secretKey";
private Logger logger = LoggerFactory.getLogger(RMQConfigure.class);
//use rocketmq.namesrv.addr first,if it is empty,than use system proerty or system env
@@ -52,9 +54,9 @@ public class RMQConfigure {
private boolean loginRequired = false;
private String accessKey;
private String accessKey = System.getProperty(ROCKET_MQ_AK_PROPERTY, System.getenv("ROCKET_MQ_AK"));
private String secretKey;
private String secretKey = System.getProperty(ROCKET_MQ_SK_PROPERTY, System.getenv("ROCKET_MQ_SK"));
private boolean useTLS = false;
@@ -67,7 +69,11 @@ public class RMQConfigure {
}
public void setAccessKey(String accessKey) {
this.accessKey = accessKey;
if (StringUtils.isNotBlank(accessKey)) {
this.accessKey = accessKey;
System.setProperty(ROCKET_MQ_AK_PROPERTY, accessKey);
logger.info("setAccessKey accessKey={}", accessKey);
}
}
public String getSecretKey() {
@@ -75,7 +81,11 @@ public class RMQConfigure {
}
public void setSecretKey(String secretKey) {
this.secretKey = secretKey;
if (StringUtils.isNotBlank(secretKey)) {
this.secretKey = secretKey;
System.setProperty(ROCKET_MQ_SK_PROPERTY, secretKey);
logger.info("setAccessKey accessKey={}", secretKey);
}
}
public String getNamesrvAddr() {