You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vo...@apache.org on 2017/12/13 11:40:11 UTC
[rocketmq] branch develop updated: [ROCKETMQ-308] Increasing name
server component network socket buffer size (#199)
This is an automated email from the ASF dual-hosted git repository.
vongosling pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 5459215 [ROCKETMQ-308] Increasing name server component network socket buffer size (#199)
5459215 is described below
commit 545921587398c5fd73fc5322ce33f55466b3fbf5
Author: fuyou001 <fu...@gmail.com>
AuthorDate: Wed Dec 13 19:40:10 2017 +0800
[ROCKETMQ-308] Increasing name server component network socket buffer size (#199)
* [ROCKETMQ-308] nameserver socket buffer use default value.
(cherry picked from commit e9fcb07)
* [ROCKETMQ-308] delete unused import
(cherry picked from commit 3bcefff)
---
.../main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java | 10 ----------
1 file changed, 10 deletions(-)
diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
index 760a61b..0a0c656 100644
--- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
+++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
@@ -32,7 +32,6 @@ import org.apache.rocketmq.common.MixAll;
import org.apache.rocketmq.common.constant.LoggerName;
import org.apache.rocketmq.common.namesrv.NamesrvConfig;
import org.apache.rocketmq.remoting.netty.NettyServerConfig;
-import org.apache.rocketmq.remoting.netty.NettySystemConfig;
import org.apache.rocketmq.remoting.protocol.RemotingCommand;
import org.apache.rocketmq.srvutil.ServerUtil;
import org.apache.rocketmq.srvutil.ShutdownHookThread;
@@ -49,15 +48,6 @@ public class NamesrvStartup {
public static NamesrvController main0(String[] args) {
System.setProperty(RemotingCommand.REMOTING_VERSION_KEY, Integer.toString(MQVersion.CURRENT_VERSION));
-
- if (null == System.getProperty(NettySystemConfig.COM_ROCKETMQ_REMOTING_SOCKET_SNDBUF_SIZE)) {
- NettySystemConfig.socketSndbufSize = 4096;
- }
-
- if (null == System.getProperty(NettySystemConfig.COM_ROCKETMQ_REMOTING_SOCKET_RCVBUF_SIZE)) {
- NettySystemConfig.socketRcvbufSize = 4096;
- }
-
try {
//PackageConflictDetect.detectFastjson();
--
To stop receiving notification emails like this one, please contact
['"commits@rocketmq.apache.org" <co...@rocketmq.apache.org>'].