improve readability of txn session close

SolaceDev · Jun 20, 2024 · 6ccf400 · 6ccf400
1 parent 486c5d3
commit 6ccf400
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...-core/src/main/java/com/solace/spring/cloud/stream/binder/util/FlowReceiverContainer.java b/...-core/src/main/java/com/solace/spring/cloud/stream/binder/util/FlowReceiverContainer.java
@@ -123,7 +123,10 @@ public void unbind() {
 				LOGGER.info("Unbinding flow receiver container {}", id);
 				flowReceiverReference.getStaleMessagesFlag().set(true);
 				flowReceiverReference.get().close();
-				Optional.ofNullable(flowReceiverReference.getTransactedSession()).ifPresent(TransactedSession::close);
+				TransactedSession transactedSession = flowReceiverReference.getTransactedSession();
+				if (transactedSession != null) {
+					transactedSession.close();
+				}
 			}
 		} finally {
 			writeLock.unlock();