opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ROCKETMQ-308] nameserver socket buffer use default value.

Browse Source
This commit is contained in:
傅冲
2017-11-02 11:12:58 +08:00
parent 461dddee2e
commit e9fcb072ba
1 changed files with 0 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
-9
View File
@@ -49,15 +49,6 @@ public class NamesrvStartup {
public static NamesrvController main0(String[] args) { public static NamesrvController main0(String[] args) {
System.setProperty(RemotingCommand.REMOTING_VERSION_KEY, Integer.toString(MQVersion.CURRENT_VERSION)); 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 { try {
//PackageConflictDetect.detectFastjson(); //PackageConflictDetect.detectFastjson();