diff --git a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpMessageRouter.java b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpMessageRouter.java index 5d5828e5..897702ac 100644 --- a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpMessageRouter.java +++ b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpMessageRouter.java @@ -77,6 +77,9 @@ public class WxCpMessageRouter { for (final Rule rule : rules) { if (rule.test(wxMessage)) { matchRules.add(rule); + if(!rule.reEnter) { + break; + } } } @@ -91,9 +94,6 @@ public class WxCpMessageRouter { public void run() { for (final Rule rule : matchRules) { rule.service(wxMessage); - if (!rule.reEnter) { - break; - } } } }); 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 07451d6f..f4122fdc 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 @@ -77,6 +77,9 @@ public class WxMpMessageRouter { for (final Rule rule : rules) { if (rule.test(wxMessage)) { matchRules.add(rule); + if(!rule.reEnter) { + break; + } } } @@ -91,9 +94,6 @@ public class WxMpMessageRouter { public void run() { for (final Rule rule : matchRules) { rule.service(wxMessage); - if (!rule.reEnter) { - break; - } } } });