| @@ -77,6 +77,9 @@ public class WxCpMessageRouter { | |||||
| for (final Rule rule : rules) { | for (final Rule rule : rules) { | ||||
| if (rule.test(wxMessage)) { | if (rule.test(wxMessage)) { | ||||
| matchRules.add(rule); | matchRules.add(rule); | ||||
| if(!rule.reEnter) { | |||||
| break; | |||||
| } | |||||
| } | } | ||||
| } | } | ||||
| @@ -91,9 +94,6 @@ public class WxCpMessageRouter { | |||||
| public void run() { | public void run() { | ||||
| for (final Rule rule : matchRules) { | for (final Rule rule : matchRules) { | ||||
| rule.service(wxMessage); | rule.service(wxMessage); | ||||
| if (!rule.reEnter) { | |||||
| break; | |||||
| } | |||||
| } | } | ||||
| } | } | ||||
| }); | }); | ||||
| @@ -77,6 +77,9 @@ public class WxMpMessageRouter { | |||||
| for (final Rule rule : rules) { | for (final Rule rule : rules) { | ||||
| if (rule.test(wxMessage)) { | if (rule.test(wxMessage)) { | ||||
| matchRules.add(rule); | matchRules.add(rule); | ||||
| if(!rule.reEnter) { | |||||
| break; | |||||
| } | |||||
| } | } | ||||
| } | } | ||||
| @@ -91,9 +94,6 @@ public class WxMpMessageRouter { | |||||
| public void run() { | public void run() { | ||||
| for (final Rule rule : matchRules) { | for (final Rule rule : matchRules) { | ||||
| rule.service(wxMessage); | rule.service(wxMessage); | ||||
| if (!rule.reEnter) { | |||||
| break; | |||||
| } | |||||
| } | } | ||||
| } | } | ||||
| }); | }); | ||||