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 63927d591f1dfabbc393f4ea7352afd79a890ff2 Author: 傅冲 <[email protected]> AuthorDate: Wed Jun 13 15:35:04 2018 +0800 #325 register nameserver add crc32 check --- .../rocketmq/namesrv/processor/DefaultRequestProcessor.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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 559e103..cd63c16 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 @@ -200,8 +200,8 @@ public class DefaultRequestProcessor implements NettyRequestProcessor { if (requestHeader.getBodyCrc32() != 0) { final int crc32 = UtilAll.crc32(request.getBody()); if (crc32 != requestHeader.getBodyCrc32()) { - log.warn("receive registerBroker request,crc32 not match,from %s", - RemotingHelper.parseChannelRemoteAddr(ctx.channel())); + log.warn(String.format("receive registerBroker request,crc32 not match,from %s", + RemotingHelper.parseChannelRemoteAddr(ctx.channel()))); response.setCode(ResponseCode.SYSTEM_ERROR); response.setRemark("crc32 not match"); return response; @@ -277,8 +277,8 @@ public class DefaultRequestProcessor implements NettyRequestProcessor { if (requestHeader.getBodyCrc32() != 0) { final int crc32 = UtilAll.crc32(request.getBody()); if (crc32 != requestHeader.getBodyCrc32()) { - log.warn("receive registerBroker request,crc32 not match,from %s", - RemotingHelper.parseChannelRemoteAddr(ctx.channel())); + log.warn(String.format("receive registerBroker request,crc32 not match,from %s", + RemotingHelper.parseChannelRemoteAddr(ctx.channel()))); response.setCode(ResponseCode.SYSTEM_ERROR); response.setRemark("crc32 not match"); return response;
