Move test customizer to TopLevelConfig in txn tests

Signed-off-by: onobc <[email protected]>

Author: onobc

spring-pulsar/src/test/java/org/springframework/pulsar/listener/PulsarListenerTxnTests.java

@@ -41,7 +41,6 @@
 import org.springframework.pulsar.listener.PulsarListenerTxnTests.ListenerWithExternalTransactionRollback.ListenerWithExternalTransactionRollbackConfig;
 import org.springframework.pulsar.listener.PulsarListenerTxnTests.RecordListenerWithCommit.RecordListenerWithCommitConfig;
 import org.springframework.pulsar.listener.PulsarListenerTxnTests.RecordListenerWithRollback.RecordListenerWithRollbackConfig;
-import org.springframework.pulsar.listener.PulsarTxnTestsBase.TestPulsarContainerPropertiesCustomizer;
 import org.springframework.pulsar.transaction.PulsarTxnTestsBase;
 import org.springframework.test.context.ContextConfiguration;
 import org.springframework.transaction.annotation.Transactional;

spring-pulsar/src/test/java/org/springframework/pulsar/listener/PulsarTxnTestsBase.java

@@ -27,6 +27,7 @@
 import org.apache.pulsar.client.api.Schema;
 import org.assertj.core.api.AbstractListAssert;
 import org.assertj.core.api.ObjectAssert;
+import org.jspecify.annotations.Nullable;
 import org.junit.jupiter.api.BeforeAll;
 import org.testcontainers.containers.PulsarContainer;
 import org.testcontainers.junit.jupiter.Testcontainers;
@@ -103,6 +104,13 @@ protected AbstractListAssert<?, List<? extends String>, String, ObjectAssert<Str
 			.get()).map(Message::getValue);
 	}
 
+	@FunctionalInterface
+	public interface TestPulsarContainerPropertiesCustomizer {
+
+		void customize(PulsarContainerProperties containerProps);
+
+	}
+
 	@Configuration
 	@EnablePulsar
 	public static class TopLevelConfig {
@@ -135,11 +143,15 @@ public PulsarConsumerFactory<?> pulsarConsumerFactory(PulsarClient pulsarClient,
 		}
 
 		@Bean
-		PulsarContainerProperties pulsarContainerProperties(PulsarAwareTransactionManager pulsarTransactionManager) {
+		PulsarContainerProperties pulsarContainerProperties(PulsarAwareTransactionManager pulsarTransactionManager,
+				@Nullable TestPulsarContainerPropertiesCustomizer containerPropsCustomizer) {
 			var containerProps = new PulsarContainerProperties();
 			containerProps.transactions().setEnabled(true);
 			containerProps.transactions().setRequired(false);
 			containerProps.transactions().setTransactionManager(pulsarTransactionManager);
+			if (containerPropsCustomizer != null) {
+				containerPropsCustomizer.customize(containerProps);
+			}
 			return containerProps;
 		}