Checkstyle fix

This commit is contained in:
Oleg Zhurakousky
2024-02-22 16:30:57 +01:00
parent 3c15eca2c9
commit 4da70ef52b

View File

@@ -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);