From a726e37ba5b8aa97211e0656639a60cc640be39a Mon Sep 17 00:00:00 2001
From: Binary Wang <binarywang@gmail.com>
Date: Sun, 12 Mar 2023 21:00:52 +0800
Subject: [PATCH] =?UTF-8?q?:art:=20=E4=BF=AE=E5=A4=8D=E9=94=99=E8=AF=AF?=
 =?UTF-8?q?=E5=BC=95=E7=94=A8=E7=9A=84=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../chanjar/weixin/mp/api/WxMpMessageRouter.java | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/weixin-java-mp/src/main/java/me/chanjar/weixin/mp/api/WxMpMessageRouter.java b/weixin-java-mp/src/main/java/me/chanjar/weixin/mp/api/WxMpMessageRouter.java
index 6d8ab429f..df6ffe7dd 100644
--- a/weixin-java-mp/src/main/java/me/chanjar/weixin/mp/api/WxMpMessageRouter.java
+++ b/weixin-java-mp/src/main/java/me/chanjar/weixin/mp/api/WxMpMessageRouter.java
@@ -5,7 +5,6 @@ import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import me.chanjar.weixin.common.api.WxErrorExceptionHandler;
 import me.chanjar.weixin.common.api.WxMessageDuplicateChecker;
-import me.chanjar.weixin.common.api.WxMessageInMemoryDuplicateChecker;
 import me.chanjar.weixin.common.api.WxMessageInMemoryDuplicateCheckerSingleton;
 import me.chanjar.weixin.common.session.InternalSession;
 import me.chanjar.weixin.common.session.InternalSessionManager;
@@ -16,10 +15,7 @@ import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
 import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
 import me.chanjar.weixin.mp.util.WxMpConfigStorageHolder;
 import org.apache.commons.lang3.StringUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
-import javax.xml.ws.Holder;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -106,8 +102,9 @@ public class WxMpMessageRouter {
     try {
       if (!this.executorService.awaitTermination(second, TimeUnit.SECONDS)) {
         this.executorService.shutdownNow();
-        if (!this.executorService.awaitTermination(second, TimeUnit.SECONDS))
+        if (!this.executorService.awaitTermination(second, TimeUnit.SECONDS)) {
           log.error("线程池未关闭！");
+        }
       }
     } catch (InterruptedException ie) {
       this.executorService.shutdownNow();
@@ -176,14 +173,16 @@ public class WxMpMessageRouter {
   /**
    * 处理不同appid微信消息
    */
-  public WxMpXmlOutMessage route(final String appid, final WxMpXmlMessage wxMessage, final Map<String, Object> context) {
+  public WxMpXmlOutMessage route(final String appid, final WxMpXmlMessage wxMessage,
+                                 final Map<String, Object> context) {
     return route(wxMessage, context, this.wxMpService.switchoverTo(appid));
   }
 
   /**
    * 处理微信消息.
    */
-  public WxMpXmlOutMessage route(final WxMpXmlMessage wxMessage, final Map<String, Object> context, WxMpService wxMpService) {
+  public WxMpXmlOutMessage route(final WxMpXmlMessage wxMessage, final Map<String, Object> context,
+                                 WxMpService wxMpService) {
     if (wxMpService == null) {
       wxMpService = this.wxMpService;
     }
@@ -218,7 +217,8 @@ public class WxMpMessageRouter {
           this.executorService.submit(() -> {
             //传入父线程的appId
             this.wxMpService.switchoverTo(appId);
-            rule.service(wxMessage, context, mpService, WxMpMessageRouter.this.sessionManager, WxMpMessageRouter.this.exceptionHandler);
+            rule.service(wxMessage, context, mpService, WxMpMessageRouter.this.sessionManager,
+              WxMpMessageRouter.this.exceptionHandler);
           })
         );
       } else {