|
@@ -225,6 +225,7 @@ public class WxMpMessageRouter {
|
|
|
if (wxMpService == null) {
|
|
|
wxMpService = this.wxMpService;
|
|
|
}
|
|
|
+
|
|
|
final WxMpService mpService = wxMpService;
|
|
|
if (isMsgDuplicated(wxMessage)) {
|
|
|
// 如果是重复消息,那么就不做处理
|
|
@@ -253,11 +254,11 @@ public class WxMpMessageRouter {
|
|
|
// 返回最后一个非异步的rule的执行结果
|
|
|
if (rule.isAsync()) {
|
|
|
//获取当前线程使用的实际appId。兼容只有一个appId,且未显式设置当前使用的appId的情况
|
|
|
- String appId = this.wxMpService.getWxMpConfigStorage().getAppId();
|
|
|
+ String appId = mpService.getWxMpConfigStorage().getAppId();
|
|
|
futures.add(
|
|
|
this.executorService.submit(() -> {
|
|
|
//传入父线程的appId
|
|
|
- this.wxMpService.switchoverTo(appId);
|
|
|
+ mpService.switchoverTo(appId);
|
|
|
rule.service(wxMessage, context, mpService, WxMpMessageRouter.this.sessionManager,
|
|
|
WxMpMessageRouter.this.exceptionHandler);
|
|
|
WxMpConfigStorageHolder.remove();
|