suzhuhong/zxjp-web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改rocket mq ak sk

Browse Source
This commit is contained in:
zhangchenbiao
2024-09-11 17:07:38 +08:00
parent 75e50f1683
commit 5a0996ed17
7 changed files with 14 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
coolstore-partner-common/src/main/java/com/cool/store/utils/RocketMqUtil.java
View File

@@ -30,8 +30,8 @@ public class RocketMqUtil {
private static final String LOCAL_INSTANCE_ID = "MQ_INST_1255228665351616_BX3wfyPO";
private static final String INSTANCE_ID_ONLINE_HD_PRE = "MQ_INST_1947409023213164_BX5N7rwl";
private static final String ACCESS_KEY = "LTAI5t5ouXZuFgxJMbQea3b2";
private static final String ACCESS_SECRET = "yuomDstRjSdihtN5zo8viDbWu8Z0ig";
private static final String ACCESS_KEY = "LTAI5tJbgtyoHUvofTaeP1RP";
private static final String ACCESS_SECRET = "myg755iCx0j4PyQkHMaUVeOr0bw1tA";
/**
* 使用AK&SK初始化账号Client
* @param accessKeyId
@@ -104,7 +104,7 @@ public class RocketMqUtil {
}
public static void initLocalGroup(String profiles) throws Exception {
Client client = RocketMqUtil.createLocalClient("LTAI5tPWCTeCyngfYLqoSGWk", "jkzIXlvNF17ne5TPPEFP1sQhcfg4Je");
Client client = RocketMqUtil.createLocalClient("LTAI5tDbJ7SVCYZe8kEtq9Up", "Kk4itOA0pxTK1uD4z3pWLGQ3ZV6VSD");
List<String> profileList = Arrays.asList(profiles.split(CommonConstants.COMMA));
if(CollectionUtils.isEmpty(profileList)){
return;