From a9b6cce0b0f71f63d3b6f5b7e8025499fdc0e6d2 Mon Sep 17 00:00:00 2001 From: crusader Date: Fri, 4 May 2018 19:11:11 +0900 Subject: [PATCH] ing --- .../container/configuration/ContainerConfiguration.java | 2 +- .../overflow/container/service/ContainerCollectorService.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/loafle/overflow/container/configuration/ContainerConfiguration.java b/src/main/java/com/loafle/overflow/container/configuration/ContainerConfiguration.java index 26f79e5..97703e2 100644 --- a/src/main/java/com/loafle/overflow/container/configuration/ContainerConfiguration.java +++ b/src/main/java/com/loafle/overflow/container/configuration/ContainerConfiguration.java @@ -71,7 +71,7 @@ public class ContainerConfiguration { return new JSONRPCClientCodec(this.objectMapper); } - @Bean(Container.RPC_CLIENT_CODEC) + @Bean() public RPCClientHandler rpcClientHandler() { return new RPCClientHandler(); } diff --git a/src/main/java/com/loafle/overflow/container/service/ContainerCollectorService.java b/src/main/java/com/loafle/overflow/container/service/ContainerCollectorService.java index 3198227..387b1d9 100644 --- a/src/main/java/com/loafle/overflow/container/service/ContainerCollectorService.java +++ b/src/main/java/com/loafle/overflow/container/service/ContainerCollectorService.java @@ -87,7 +87,7 @@ public class ContainerCollectorService implements CollectorService { logger.error("Cannot get data from crawler[%s] %s", sensorConfig.getCrawler().getName(), e.getMessage()); } }; - ScheduledFuture sf = this.scheduledExecutorService.schedule(task, interval, TimeUnit.SECONDS); + ScheduledFuture sf = this.scheduledExecutorService.scheduleWithFixedDelay(task, 0, interval, TimeUnit.SECONDS); this.scheduleMap.put(sensorConfig.getConfigID(), sf); }