[rocketmq] branch develop updated: [ISSUE #3200] Fix code style in 'NettySystemConfig.java'

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong 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 1eaa38f  [ISSUE #3200] Fix code style in 'NettySystemConfig.java'
1eaa38f is described below

commit 1eaa38f63989fc06fa50a1aa0f162d8050982ce8
Author: guyinyou <36399867+guyin...@users.noreply.github.com>
AuthorDate: Fri Jul 30 19:06:27 2021 +0800

    [ISSUE #3200] Fix code style in 'NettySystemConfig.java'
---
 .../rocketmq/remoting/netty/NettySystemConfig.java    | 19 +++++++++----------
 1 file changed, 9 insertions(+), 10 deletions(-)

diff --git 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettySystemConfig.java
 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettySystemConfig.java
index ef767a3..d4c3749 100644
--- 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettySystemConfig.java
+++ 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettySystemConfig.java
@@ -29,16 +29,15 @@ public class NettySystemConfig {
     public static final String 
COM_ROCKETMQ_REMOTING_CLIENT_ONEWAY_SEMAPHORE_VALUE =
         "com.rocketmq.remoting.clientOnewaySemaphoreValue";
     public static final String COM_ROCKETMQ_REMOTING_CLIENT_WORKER_SIZE =
-      "com.rocketmq.remoting.client.worker.size";
+        "com.rocketmq.remoting.client.worker.size";
     public static final String COM_ROCKETMQ_REMOTING_CLIENT_CONNECT_TIMEOUT =
-      "com.rocketmq.remoting.client.connect.timeout";
+        "com.rocketmq.remoting.client.connect.timeout";
     public static final String 
COM_ROCKETMQ_REMOTING_CLIENT_CHANNEL_MAX_IDLE_SECONDS =
-      "com.rocketmq.remoting.client.channel.maxIdleTimeSeconds";
+        "com.rocketmq.remoting.client.channel.maxIdleTimeSeconds";
     public static final String 
COM_ROCKETMQ_REMOTING_CLIENT_CLOSE_SOCKET_IF_TIMEOUT =
-      "com.rocketmq.remoting.client.closeSocketIfTimeout";
+        "com.rocketmq.remoting.client.closeSocketIfTimeout";
 
-
-  public static final boolean NETTY_POOLED_BYTE_BUF_ALLOCATOR_ENABLE = //
+    public static final boolean NETTY_POOLED_BYTE_BUF_ALLOCATOR_ENABLE = //
         
Boolean.parseBoolean(System.getProperty(COM_ROCKETMQ_REMOTING_NETTY_POOLED_BYTE_BUF_ALLOCATOR_ENABLE,
 "false"));
     public static final int CLIENT_ASYNC_SEMAPHORE_VALUE = //
         
Integer.parseInt(System.getProperty(COM_ROCKETMQ_REMOTING_CLIENT_ASYNC_SEMAPHORE_VALUE,
 "65535"));
@@ -49,11 +48,11 @@ public class NettySystemConfig {
     public static int socketRcvbufSize =
         
Integer.parseInt(System.getProperty(COM_ROCKETMQ_REMOTING_SOCKET_RCVBUF_SIZE, 
"65535"));
     public static int clientWorkerSize =
-      
Integer.parseInt(System.getProperty(COM_ROCKETMQ_REMOTING_CLIENT_WORKER_SIZE, 
"4"));
+        
Integer.parseInt(System.getProperty(COM_ROCKETMQ_REMOTING_CLIENT_WORKER_SIZE, 
"4"));
     public static int connectTimeoutMillis =
-      
Integer.parseInt(System.getProperty(COM_ROCKETMQ_REMOTING_CLIENT_CONNECT_TIMEOUT,
 "3000"));
+        
Integer.parseInt(System.getProperty(COM_ROCKETMQ_REMOTING_CLIENT_CONNECT_TIMEOUT,
 "3000"));
     public static int clientChannelMaxIdleTimeSeconds =
-      
Integer.parseInt(System.getProperty(COM_ROCKETMQ_REMOTING_CLIENT_CHANNEL_MAX_IDLE_SECONDS,
 "120"));
+        
Integer.parseInt(System.getProperty(COM_ROCKETMQ_REMOTING_CLIENT_CHANNEL_MAX_IDLE_SECONDS,
 "120"));
     public static boolean clientCloseSocketIfTimeout =
-      
Boolean.parseBoolean(System.getProperty(COM_ROCKETMQ_REMOTING_CLIENT_CLOSE_SOCKET_IF_TIMEOUT,
 "true"));
+        
Boolean.parseBoolean(System.getProperty(COM_ROCKETMQ_REMOTING_CLIENT_CLOSE_SOCKET_IF_TIMEOUT,
 "true"));
 }