You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by ke...@apache.org on 2020/04/12 10:14:37 UTC

[skywalking] 01/01: Pause a while when heart beating

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

kezhenxu94 pushed a commit to branch kezhenxu94-patch-1
in repository https://gitbox.apache.org/repos/asf/skywalking.git

commit caee1549fb5c627dc07ea70b9053f344d3bc5103
Author: kezhenxu94 <ke...@apache.org>
AuthorDate: Sun Apr 12 18:14:19 2020 +0800

    Pause a while when heart beating
---
 .../skywalking/apm/agent/core/remote/ServiceManagementClient.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/remote/ServiceManagementClient.java b/apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/remote/ServiceManagementClient.java
index 5211efe..b2f8a31 100755
--- a/apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/remote/ServiceManagementClient.java
+++ b/apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/remote/ServiceManagementClient.java
@@ -86,7 +86,7 @@ public class ServiceManagementClient implements BootService, Runnable, GRPCChann
     @Override
     public void boot() {
         serviceRegisterFuture = Executors.newSingleThreadScheduledExecutor(
-            new DefaultNamedThreadFactory("ServiceRegisterClient")
+            new DefaultNamedThreadFactory("ServiceManagementClient")
         ).scheduleAtFixedRate(
             new RunnableWithExceptionProtection(
                 this,
@@ -132,6 +132,8 @@ public class ServiceManagementClient implements BootService, Runnable, GRPCChann
                                                    .build());
 
                         ServiceManager.INSTANCE.findService(CommandService.class).receiveCommand(commands);
+
+                        Thread.sleep(1000L);
                     }
                 }
             } catch (Throwable t) {