# enoch agent

enoch-agent-spring-boot-starter/src/main/java/cn/quantgroup/tech/enoch/agent/TimerTask.java → enoch-agent-spring-boot-starter/src/main/java/cn/quantgroup/tech/enoch/agent/AgentReportTask.java

 package cn.quantgroup.tech.enoch.agent;
+
 import cn.quantgroup.tech.enoch.agent.report.IReportService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.EnableScheduling;
@@ -11,7 +12,7 @@ import org.springframework.stereotype.Component;
  */
 @Component
 @EnableScheduling
-public class TimerTask {
+public class AgentReportTask {
 
     @Autowired
     private IReportService reportService;

enoch-agent-spring-boot-starter/src/main/java/cn/quantgroup/tech/enoch/agent/configuration/EnochAgentAutoConfiguration.java

 package cn.quantgroup.tech.enoch.agent.configuration;
 
+import cn.quantgroup.tech.enoch.agent.AgentReportTask;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.producer.ProducerConfig;
 import org.apache.kafka.common.serialization.StringSerializer;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.kafka.core.DefaultKafkaProducerFactory;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.kafka.core.ProducerFactory;
+import org.springframework.scheduling.annotation.SchedulingConfigurer;
+import org.springframework.scheduling.config.ScheduledTaskRegistrar;
 
 import java.util.HashMap;
+import java.util.concurrent.ScheduledThreadPoolExecutor;
 
 /**
  * @author: amen
@@ -21,16 +25,15 @@ import java.util.HashMap;
  */
 @Slf4j
 @Configuration
-@EnableConfigurationProperties({EnochAgentProperties.class})
+@ComponentScan(basePackageClasses = {AgentReportTask.class})
+@EnableConfigurationProperties(EnochAgentProperties.class)
 public class EnochAgentAutoConfiguration {
 
     @Autowired
     private EnochAgentProperties enochAgentProperties;
 
-
     @Bean
     @ConditionalOnBean(EnochAgentProperties.class)
-    @ConditionalOnMissingBean
     public ProducerFactory<String, String> producerFactory() {
         HashMap<String, Object> config = new HashMap<>(16);
         config.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, enochAgentProperties.getKafkaHost());
@@ -47,4 +50,12 @@ public class EnochAgentAutoConfiguration {
     }
 
 
+    @Configuration
+    public static class ScheduleConfig implements SchedulingConfigurer {
+        @Override
+        public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
+            ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(2);
+            taskRegistrar.setScheduler(executor);
+        }
+    }
 }
\ No newline at end of file

enoch-agent-spring-boot-starter/src/main/java/cn/quantgroup/tech/enoch/agent/configuration/EnochAgentProperties.java

@@ -12,6 +12,5 @@ import org.springframework.boot.context.properties.ConfigurationProperties;
 public class EnochAgentProperties {
     private String kafkaHost;
     private String kafkaTopic;
-    private Long reportRate = 30000L;
 
 }

enoch-agent-spring-boot-starter/src/main/java/cn/quantgroup/tech/enoch/agent/report/impl/ReportServiceImpl.java

@@ -48,8 +48,8 @@ public class ReportServiceImpl implements IReportService {
 
     @Override
     public void report() {
-        log.info("enoch.agent report");
         int size = arrayBlockingQueue.size();
+        log.info("enoch.agent report data, size: {}", size);
         List<Map<String, Object>> slice = new ArrayList<>(size);
         arrayBlockingQueue.drainTo(slice, size);
         Map<String, Object> pushPackage = new HashMap<>(6);
@@ -65,8 +65,7 @@ public class ReportServiceImpl implements IReportService {
 
     @Override
     public void collect() {
-        log.info("enoch.agent collect");
-        //todo 添加timestamp
+        log.info("enoch.agent collect data");
         HashMap<String, Object> endPoints = new HashMap<>(16);
         endPoints.put("health", healthEndpoint.invoke());
         endPoints.put("metrics", metricsEndpoint.invoke());