[MINOR] Remove the unnecessary boxing (#731)

apache · Jan 22, 2022 · 8fcddf0 · 8fcddf0
1 parent 93b2442
commit 8fcddf0
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/...tmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfiguration.java b/...tmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfiguration.java
@@ -100,7 +100,7 @@ public void init() {
         if (StringUtils.isNotBlank(consumeTimeoutStr)) {
             Preconditions.checkState(StringUtils.isNumeric(consumeTimeoutStr),
                     String.format("%s error", ConfKeys.KEYS_EVENTMESH_ROCKETMQ_CLIENT_CONSUME_TIMEOUT));
-            consumeTimeout = Long.valueOf(consumeTimeoutStr);
+            consumeTimeout = Long.parseLong(consumeTimeoutStr);
         }
 
         String clientPullBatchSizeStr =

diff --git a/...in/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HeartBeatProcessor.java b/...in/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HeartBeatProcessor.java
@@ -135,7 +135,7 @@ public void processRequest(ChannelHandlerContext ctx, AsyncContext<HttpCommand>
                 String remoteAddr = RemotingHelper.parseChannelRemoteAddr(ctx.channel());
                 String user = heartbeatRequestHeader.getUsername();
                 String pass = heartbeatRequestHeader.getPasswd();
-                int requestCode = Integer.valueOf(heartbeatRequestHeader.getCode());
+                int requestCode = Integer.parseInt(heartbeatRequestHeader.getCode());
                 try {
                     Acl.doAclCheckInHttpHeartbeat(remoteAddr, user, pass, sys, client.topic, requestCode);
                 } catch (Exception e) {

diff --git a/...g/apache/eventmesh/runtime/core/protocol/tcp/client/rebalance/EventmeshRebalanceImpl.java b/...g/apache/eventmesh/runtime/core/protocol/tcp/client/rebalance/EventmeshRebalanceImpl.java
@@ -169,7 +169,7 @@ private void doRedirect(String group, String purpose, int judge, List<String> ev
             String newProxyIp = eventMeshRecommendResult.get(i).split(":")[0];
             String newProxyPort = eventMeshRecommendResult.get(i).split(":")[1];
             String redirectSessionAddr = EventMeshTcp2Client.redirectClient2NewEventMesh(eventMeshTCPServer, newProxyIp,
-                    Integer.valueOf(newProxyPort), sessionList.get(i), eventMeshTCPServer.getClientSessionGroupMapping());
+                    Integer.parseInt(newProxyPort), sessionList.get(i), eventMeshTCPServer.getClientSessionGroupMapping());
             logger.info("doRebalance,redirect sessionAddr:{}", redirectSessionAddr);
             try {
                 Thread.sleep(eventMeshTCPServer.getEventMeshTCPConfiguration().sleepIntervalInRebalanceRedirectMills);
@@ -192,7 +192,7 @@ public int caculateRedirectNum(String eventMeshName, String group, String purpos
                                    Map<String, Integer> clientDistributionMap) throws Exception {
         int sum = 0;
         for (Integer item : clientDistributionMap.values()) {
-            sum += item.intValue();
+            sum += item;
         }
         int currentNum = 0;
         if (clientDistributionMap.get(eventMeshName) != null) {

diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
@@ -24,7 +24,7 @@ public class ValueComparator implements Comparator<Map.Entry<String, Integer>> {
     @Override
     public int compare(Map.Entry<String, Integer> x, Map.Entry<String, Integer> y) {
         if (x.getValue().intValue() != y.getValue().intValue()) {
-            return x.getValue().intValue() - y.getValue().intValue();
+            return x.getValue() - y.getValue();
         } else {
             return x.getKey().compareTo(y.getKey());
         }