diff --git a/spring-cloud-consul-binder/src/main/java/org/springframework/cloud/consul/binder/ConsulInboundMessageProducer.java b/spring-cloud-consul-binder/src/main/java/org/springframework/cloud/consul/binder/ConsulInboundMessageProducer.java index 292de64d..80050f33 100644 --- a/spring-cloud-consul-binder/src/main/java/org/springframework/cloud/consul/binder/ConsulInboundMessageProducer.java +++ b/spring-cloud-consul-binder/src/main/java/org/springframework/cloud/consul/binder/ConsulInboundMessageProducer.java @@ -84,6 +84,7 @@ public class ConsulInboundMessageProducer extends MessageProducerSupport { if (this.eventsHandle != null) { this.eventsHandle.cancel(true); } + this.scheduler.shutdown(); } // @Scheduled(fixedDelayString = "${spring.cloud.consul.binder.eventDelay:30000}")