opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-01 15:47:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: DefaultMQAdminExt setting socksProxy has no effect (#5533)

Browse Source 
Co-authored-by: changfeng <yongming.cym@alibaba-inc.com>
This commit is contained in:
陈永明
2022-11-17 00:39:57 +08:00
committed by GitHub
parent 809ff6b3e0
commit b2de9e1cdf
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
+4 -2
View File
@@ -167,8 +167,10 @@ public class DefaultMQAdminExtImpl implements MQAdminExt, MQAdminExtInner {
this.defaultMQAdminExt.changeInstanceNameToPID();
String proxyConfig = System.getenv(SOCKS_PROXY_JSON);
this.defaultMQAdminExt.setSocksProxyConfig(StringUtils.isNotEmpty(proxyConfig) ? proxyConfig : "{}");
if ("{}".equals(this.defaultMQAdminExt.getSocksProxyConfig())) {
String proxyConfig = System.getenv(SOCKS_PROXY_JSON);
this.defaultMQAdminExt.setSocksProxyConfig(StringUtils.isNotEmpty(proxyConfig) ? proxyConfig : "{}");
}
this.mqClientInstance = MQClientManager.getInstance().getOrCreateMQClientInstance(this.defaultMQAdminExt, rpcHook);