diff --git a/spring-cloud-netflix-hystrix-stream/src/main/java/org/springframework/cloud/netflix/hystrix/stream/HystrixStreamTask.java b/spring-cloud-netflix-hystrix-stream/src/main/java/org/springframework/cloud/netflix/hystrix/stream/HystrixStreamTask.java index 28f14affe..32cbba0c7 100644 --- a/spring-cloud-netflix-hystrix-stream/src/main/java/org/springframework/cloud/netflix/hystrix/stream/HystrixStreamTask.java +++ b/spring-cloud-netflix-hystrix-stream/src/main/java/org/springframework/cloud/netflix/hystrix/stream/HystrixStreamTask.java @@ -89,7 +89,7 @@ public class HystrixStreamTask implements ApplicationContextAware { } // TODO: use integration to split this up? - @Scheduled(fixedRateString = "${hystrix.stream.queue.sendRate:500}") + @Scheduled(fixedRateString = "${hystrix.stream.queue.sendRate:${hystrix.stream.queue.send-rate:500}}") public void sendMetrics() { ArrayList metrics = new ArrayList<>(); this.jsonMetrics.drainTo(metrics); @@ -117,7 +117,7 @@ public class HystrixStreamTask implements ApplicationContextAware { } } - @Scheduled(fixedRateString = "${hystrix.stream.queue.gatherRate:500}") + @Scheduled(fixedRateString = "${hystrix.stream.queue.gatherRate:${hystrix.stream.queue.gather-rate:500}}") public void gatherMetrics() { try { // command metrics