diff --git a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java index 03f91359c..4e11bc7a1 100644 --- a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java +++ b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java @@ -332,7 +332,7 @@ public final class StreamBridge implements StreamOperations, SmartInitializingSi logger.warn("Failed to terminate executor. Terminating current tasks."); this.executorService.shutdownNow(); } - + this.executorService = null; this.async = false; channelCache.keySet().forEach(bindingService::unbindProducers);