From 3e6f9e92d93ffa8d53e52b6e4614076f8c3171cc Mon Sep 17 00:00:00 2001 From: javahongxi Date: Sun, 11 Aug 2019 22:53:43 +0800 Subject: [PATCH] netty --- .../whatsmars/netty/objectecho/ObjectEchoServerHandler.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/whatsmars-rpc/whatsmars-netty/src/main/java/org/hongxi/whatsmars/netty/objectecho/ObjectEchoServerHandler.java b/whatsmars-rpc/whatsmars-netty/src/main/java/org/hongxi/whatsmars/netty/objectecho/ObjectEchoServerHandler.java index 54781052..9fe3cf1e 100755 --- a/whatsmars-rpc/whatsmars-netty/src/main/java/org/hongxi/whatsmars/netty/objectecho/ObjectEchoServerHandler.java +++ b/whatsmars-rpc/whatsmars-netty/src/main/java/org/hongxi/whatsmars/netty/objectecho/ObjectEchoServerHandler.java @@ -26,11 +26,11 @@ import java.util.concurrent.atomic.AtomicInteger; */ public class ObjectEchoServerHandler extends ChannelInboundHandlerAdapter { - private int counter; + private int count; @Override public void channelRead(ChannelHandlerContext ctx, Object msg) { - if (counter++ % 1000 == 0) { + if (count++ % 1000 == 0) { System.out.println("received Object: " + msg); } // Echo back the received object to the client. -- GitLab