更新流控文案

jerry6290 · Nov 15, 2013 · a2ab1dd · a2ab1dd
1 parent 66ab19d
commit a2ab1dd
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...tmq-remoting/src/main/java/com/alibaba/rocketmq/remoting/netty/NettyRemotingAbstract.java b/...tmq-remoting/src/main/java/com/alibaba/rocketmq/remoting/netty/NettyRemotingAbstract.java
@@ -212,13 +212,13 @@ public void operationComplete(ChannelFuture future) throws Exception {
             }
             catch (RejectedExecutionException e) {
                 plog.warn(RemotingHelper.parseChannelRemoteAddr(ctx.channel()) //
-                        + ", system thread pool busy, RejectedExecutionException " //
+                        + ", too many requests and system thread pool busy, RejectedExecutionException " //
                         + pair.getObject2().toString() //
                         + " request code: " + cmd.getCode());
                 if (!cmd.isOnewayRPC()) {
                     final RemotingCommand response =
                             RemotingCommand.createResponseCommand(ResponseCode.SYSTEM_BUSY_VALUE,
-                                "system thread pool busy, please try another node");
+                                "too many requests and system thread pool busy, please try another server");
                     response.setOpaque(cmd.getOpaque());
                     ctx.writeAndFlush(response);
                 }