From a64ace4700aa300385c92864f73cb3c115bd00a6 Mon Sep 17 00:00:00 2001 From: Spencer Gibb Date: Fri, 9 Dec 2016 11:44:35 -0700 Subject: [PATCH] Shutdown scheduler in ConsulInboundMessageProducer fixes gh-259 --- .../cloud/consul/binder/ConsulInboundMessageProducer.java | 1 + 1 file changed, 1 insertion(+) 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}")