From 4da70ef52beca0573f3e3b653e87657d4986cd4e Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Thu, 22 Feb 2024 16:30:57 +0100 Subject: [PATCH] Checkstyle fix --- .../org/springframework/cloud/stream/function/StreamBridge.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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);