Temp disable only Reactive tests (debug long running CI)

Author: onobc

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

@@ -478,7 +478,7 @@ void basicDefaultConsumerWithCustomObjectMapper() throws Exception {
 	@Nested
 	class WithStartupFailures {
 
-		// @Test
+		@Test
 		void whenPolicyIsStopThenExceptionIsThrown() {
 			DefaultPulsarConsumerFactory<String> consumerFactory = mock(DefaultPulsarConsumerFactory.class);
 			var containerProps = new PulsarContainerProperties();
@@ -502,7 +502,7 @@ void whenPolicyIsStopThenExceptionIsThrown() {
 					.hasFieldOrPropertyWithValue("container", container)));
 		}
 
-		// @Test
+		@Test
 		void whenPolicyIsContinueThenExceptionIsNotThrown() {
 			DefaultPulsarConsumerFactory<String> consumerFactory = mock(DefaultPulsarConsumerFactory.class);
 			var containerProps = new PulsarContainerProperties();
@@ -524,7 +524,7 @@ void whenPolicyIsContinueThenExceptionIsNotThrown() {
 					.hasFieldOrPropertyWithValue("container", container)));
 		}
 
-		// @Test
+		@Test
 		void whenPolicyIsRetryAndRetriesAreExhaustedThenContainerDoesNotStart() {
 			DefaultPulsarConsumerFactory<String> consumerFactory = mock(DefaultPulsarConsumerFactory.class);
 			var retryCount = new AtomicInteger(0);
@@ -575,7 +575,7 @@ public <T, E extends Throwable> void onError(RetryContext context, RetryCallback
 					.hasFieldOrPropertyWithValue("container", container)));
 		}
 
-		// @Test
+		@Test
 		void whenPolicyIsRetryAndRetryIsSuccessfulThenContainerStarts() throws Exception {
 			var topic = "dpmlct-wsf-retry";
 			var pulsarClient = PulsarClient.builder()

spring-pulsar/src/test/java/org/springframework/pulsar/reader/DefaultPulsarMessageReaderContainerTests.java

@@ -196,7 +196,7 @@ private void safeStopContainer(PulsarMessageReaderContainer container) {
 	@Nested
 	class WithStartupFailures {
 
-		// @Test
+		@Test
 		void whenPolicyIsStopThenExceptionIsThrown() throws Exception {
 			DefaultPulsarReaderFactory<String> readerFactory = mock(DefaultPulsarReaderFactory.class);
 			var containerProps = new PulsarReaderContainerProperties();
@@ -220,7 +220,7 @@ void whenPolicyIsStopThenExceptionIsThrown() throws Exception {
 					.hasFieldOrPropertyWithValue("container", container)));
 		}
 
-		// @Test
+		@Test
 		void whenPolicyIsContinueThenExceptionIsNotThrown() throws Exception {
 			DefaultPulsarReaderFactory<String> readerFactory = mock(DefaultPulsarReaderFactory.class);
 			var containerProps = new PulsarReaderContainerProperties();
@@ -242,7 +242,7 @@ void whenPolicyIsContinueThenExceptionIsNotThrown() throws Exception {
 					.hasFieldOrPropertyWithValue("container", container)));
 		}
 
-		// @Test
+		@Test
 		void whenPolicyIsRetryAndRetriesAreExhaustedThenContainerDoesNotStart() throws Exception {
 			DefaultPulsarReaderFactory<String> readerFactory = mock(DefaultPulsarReaderFactory.class);
 			var retryCount = new AtomicInteger(0);
@@ -293,7 +293,7 @@ public <T, E extends Throwable> void onError(RetryContext context, RetryCallback
 					.hasFieldOrPropertyWithValue("container", container)));
 		}
 
-		// @Test
+		@Test
 		void whenPolicyIsRetryAndRetryIsSuccessfulThenContainerStarts() throws Exception {
 			var topic = "dpmlct-wsf-retry";
 			var readerFactory = spy(new DefaultPulsarReaderFactory<String>(pulsarClient, List.of((readerBuilder) -> {