Check transaction enabled

rbleuse · sobychacko · commit ad1ccc165cc3 · 2026-04-13T10:46:16.000-04:00
Signed-off-by: Rémi Bleuse &lt;remi.bleuse@gmail.com&gt;
diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java b/spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java
@@ -555,7 +555,9 @@ private void checkIfPausedAndHandleAccordingly() {
 		}
 
 		private boolean transactional() {
-			return this.transactionTemplate != null && this.transactionManager != null;
+			return this.transactionTemplate != null
+					&& this.transactionManager != null
+					&& this.containerProperties.transactions().isEnabled();
 		}
 
 		private void invokeRecordListener(Messages<T> messages, AtomicBoolean inRetryMode) {

Original file line number	Diff line number	Diff line change
`@@ -555,7 +555,9 @@ private void checkIfPausedAndHandleAccordingly() {`
`555`	`555`	`}`
`556`	`556`
`557`	`557`	`private boolean transactional() {`
`558`		`- return this.transactionTemplate != null && this.transactionManager != null;`
	`558`	`+ return this.transactionTemplate != null`
	`559`	`+ && this.transactionManager != null`
	`560`	`+ && this.containerProperties.transactions().isEnabled();`
`559`	`561`	`}`
`560`	`562`
`561`	`563`	`private void invokeRecordListener(Messages<T> messages, AtomicBoolean inRetryMode) {`