Skip to content

H
haoban-manage3.0
Commit 491662b8 by 徐高华
Options

分队列

parent 072049b4
Showing with 4 additions and 10 deletions
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/MemberUnionidRelatedApiServiceImpl.java
...@@ -1188,13 +1188,10 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -1188,13 +1188,10 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
DealQywxExternalUserPojo dealQywxExternalUserPojo = new DealQywxExternalUserPojo(); DealQywxExternalUserPojo dealQywxExternalUserPojo = new DealQywxExternalUserPojo();
dealQywxExternalUserPojo.setType(DealQywxExternalUserPojo.DealType.del.getType()); dealQywxExternalUserPojo.setType(DealQywxExternalUserPojo.DealType.del.getType());
dealQywxExternalUserPojo.setData(dto); dealQywxExternalUserPojo.setData(dto);
String mqName = "dealQywxExternalUserMq" ;
if(this.mqCheck(dto)) {
mqName = "dealQywxExternalUserMq2";
}
GicMQClient instance = GICMQClientUtil.getClientInstance(); GicMQClient instance = GICMQClientUtil.getClientInstance();
try { try {
instance.sendMessage(mqName, JSONObject.toJSONString(dealQywxExternalUserPojo)); instance.sendMessage("dealQywxExternalUserMq3", JSONObject.toJSONString(dealQywxExternalUserPojo));
} catch (Exception e) { } catch (Exception e) {
log.info("异步处理异常：{}", e); log.info("异步处理异常：{}", e);
} }
...@@ -1205,13 +1202,10 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA ...@@ -1205,13 +1202,10 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
DealQywxExternalUserPojo dealQywxExternalUserPojo = new DealQywxExternalUserPojo(); DealQywxExternalUserPojo dealQywxExternalUserPojo = new DealQywxExternalUserPojo();
dealQywxExternalUserPojo.setType(DealQywxExternalUserPojo.DealType.edit.getType()); dealQywxExternalUserPojo.setType(DealQywxExternalUserPojo.DealType.edit.getType());
dealQywxExternalUserPojo.setData(dto); dealQywxExternalUserPojo.setData(dto);
String mqName = "dealQywxExternalUserMq" ;
if(this.mqCheck(dto)) {
mqName = "dealQywxExternalUserMq2";
}
GicMQClient instance = GICMQClientUtil.getClientInstance(); GicMQClient instance = GICMQClientUtil.getClientInstance();
try { try {
instance.sendMessage(mqName, JSONObject.toJSONString(dealQywxExternalUserPojo)); instance.sendMessage("dealQywxExternalUserMq3", JSONObject.toJSONString(dealQywxExternalUserPojo));
} catch (Exception e) { } catch (Exception e) {
log.info("异步处理异常：{}", e); log.info("异步处理异常：{}", e);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment