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 60ddb59df..7e22cdb75 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 @@ -192,7 +192,8 @@ public final class StreamBridge implements StreamOperations, SmartInitializingSi lock.lock(); try { functionToInvoke = this.getStreamBridgeFunction(outputContentType.toString(), producerProperties); - } finally { + } + finally { lock.unlock(); } @@ -211,8 +212,9 @@ public final class StreamBridge implements StreamOperations, SmartInitializingSi Message resultMessage; lock.lock(); try { - resultMessage = (Message)functionToInvoke.apply(messageToSend); - } finally { + resultMessage = (Message) functionToInvoke.apply(messageToSend); + } + finally { lock.unlock(); }