ing
This commit is contained in:
parent
40e22f3861
commit
a9b6cce0b0
|
@ -71,7 +71,7 @@ public class ContainerConfiguration {
|
||||||
return new JSONRPCClientCodec(this.objectMapper);
|
return new JSONRPCClientCodec(this.objectMapper);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Bean(Container.RPC_CLIENT_CODEC)
|
@Bean()
|
||||||
public RPCClientHandler rpcClientHandler() {
|
public RPCClientHandler rpcClientHandler() {
|
||||||
return new RPCClientHandler();
|
return new RPCClientHandler();
|
||||||
}
|
}
|
||||||
|
|
|
@ -87,7 +87,7 @@ public class ContainerCollectorService implements CollectorService {
|
||||||
logger.error("Cannot get data from crawler[%s] %s", sensorConfig.getCrawler().getName(), e.getMessage());
|
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);
|
this.scheduleMap.put(sensorConfig.getConfigID(), sf);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user