From cb46a66a8ba9fca79f97a2d6fb9d107bb66f32a7 Mon Sep 17 00:00:00 2001 From: dongeforever Date: Tue, 4 Dec 2018 10:59:38 +0800 Subject: [PATCH] Add notes --- .../main/java/org/apache/rocketmq/broker/BrokerController.java | 1 + 1 file changed, 1 insertion(+) diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java index 796b72ef..e649665a 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java @@ -508,6 +508,7 @@ public class BrokerController { @Override public void doBeforeRequest(String remoteAddr, RemotingCommand request) { + //Do not catch the exception validator.validate(validator.parse(request, remoteAddr)); } -- GitLab