[ISSUE #2255] simplify the code (#2259)

* simplify the code * format code
apache · Nov 27, 2022 · dd2a9e9 · dd2a9e9
1 parent b318fbc
commit dd2a9e9
Showing 1 changed file with 12 additions and 15 deletions.
diff --git a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/PubClientImpl.java b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/impl/PubClientImpl.java
@@ -41,9 +41,9 @@
 
 public class PubClientImpl extends TCPClient implements PubClient {
 
-    private Logger publogger = LoggerFactory.getLogger(this.getClass());
+    private final Logger publogger = LoggerFactory.getLogger(this.getClass());
 
-    private UserAgent userAgent;
+    private final UserAgent userAgent;
 
     private ReceiveMsgHook callback;
 
@@ -79,19 +79,16 @@ public void close() {
     }
 
     public void heartbeat() throws Exception {
-        task = scheduler.scheduleAtFixedRate(new Runnable() {
-            @Override
-            public void run() {
-                try {
-                    if (!isActive()) {
-                        PubClientImpl.this.reconnect();
-                    }
-                    Package msg = MessageUtils.heartBeat();
-                    publogger.debug("PubClientImpl|{}|send heartbeat|Command={}|msg={}", clientNo, msg.getHeader().getCommand(), msg);
-                    PubClientImpl.this.dispatcher(msg, ClientConstants.DEFAULT_TIMEOUT_IN_MILLISECONDS);
-                } catch (Exception e) {
-                    //ignore
+        task = scheduler.scheduleAtFixedRate(() -> {
+            try {
+                if (!isActive()) {
+                    PubClientImpl.this.reconnect();
                 }
+                Package msg = MessageUtils.heartBeat();
+                publogger.debug("PubClientImpl|{}|send heartbeat|Command={}|msg={}", clientNo, msg.getHeader().getCommand(), msg);
+                PubClientImpl.this.dispatcher(msg, ClientConstants.DEFAULT_TIMEOUT_IN_MILLISECONDS);
+            } catch (Exception e) {
+                //ignore
             }
         }, ClientConstants.HEARTBEAT, ClientConstants.HEARTBEAT, TimeUnit.MILLISECONDS);
     }
@@ -116,7 +113,7 @@ private void hello() throws Exception {
      */
     @Override
     public Package rr(Package msg, long timeout) throws Exception {
-        publogger.info("PubClientImpl|{}|rr|send|Command={}|msg={}", clientNo, msg.getHeader().getCommand().REQUEST_TO_SERVER, msg);
+        publogger.info("PubClientImpl|{}|rr|send|Command={}|msg={}", clientNo, Command.REQUEST_TO_SERVER, msg);
         return dispatcher(msg, timeout);
     }