You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2018/06/22 09:11:25 UTC
[rocketmq] 05/08: #325 register nameserver add crc32 check
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 1e2aefecce4d062f93eb17d771cc0a07d792c92a
Author: 傅冲 <yu...@alibaba-inc.com>
AuthorDate: Wed Jun 13 14:50:24 2018 +0800
#325 register nameserver add crc32 check
---
.../org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
index bdea8b9..559e103 100644
--- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
+++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
@@ -204,6 +204,8 @@ public class DefaultRequestProcessor implements NettyRequestProcessor {
RemotingHelper.parseChannelRemoteAddr(ctx.channel()));
response.setCode(ResponseCode.SYSTEM_ERROR);
response.setRemark("crc32 not match");
+ return response;
+
}
}
@@ -279,6 +281,7 @@ public class DefaultRequestProcessor implements NettyRequestProcessor {
RemotingHelper.parseChannelRemoteAddr(ctx.channel()));
response.setCode(ResponseCode.SYSTEM_ERROR);
response.setRemark("crc32 not match");
+ return response;
}
}