Skip to content

Commit 9f4e8fe

Browse files
committed
Temp disable tests (debug long running CI)
1 parent 4eb7fa8 commit 9f4e8fe

File tree

3 files changed

+12
-12
lines changed

3 files changed

+12
-12
lines changed

spring-pulsar-reactive/src/test/java/org/springframework/pulsar/reactive/listener/DefaultReactivePulsarMessageListenerContainerTests.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -410,7 +410,7 @@ private void safeStopContainer(ReactivePulsarMessageListenerContainer<?> contain
410410
@Nested
411411
class WithStartupFailures {
412412

413-
@Test
413+
// @Test
414414
void whenPolicyIsStopThenExceptionIsThrown() throws Exception {
415415
DefaultReactivePulsarConsumerFactory<String> consumerFactory = mock(
416416
DefaultReactivePulsarConsumerFactory.class);
@@ -431,7 +431,7 @@ void whenPolicyIsStopThenExceptionIsThrown() throws Exception {
431431
assertThat(container.isRunning()).isFalse();
432432
}
433433

434-
@Test
434+
// @Test
435435
void whenPolicyIsContinueThenExceptionIsNotThrown() throws Exception {
436436
DefaultReactivePulsarConsumerFactory<String> consumerFactory = mock(
437437
DefaultReactivePulsarConsumerFactory.class);
@@ -450,7 +450,7 @@ void whenPolicyIsContinueThenExceptionIsNotThrown() throws Exception {
450450
assertThat(container.isRunning()).isFalse();
451451
}
452452

453-
@Test
453+
// @Test
454454
void whenPolicyIsRetryAndRetriesAreExhaustedThenContainerDoesNotStart() throws Exception {
455455
DefaultReactivePulsarConsumerFactory<String> consumerFactory = mock(
456456
DefaultReactivePulsarConsumerFactory.class);
@@ -494,7 +494,7 @@ public <T, E extends Throwable> void onError(RetryContext context, RetryCallback
494494
verify(consumerFactory, times(3)).createConsumer(any(), any());
495495
}
496496

497-
@Test
497+
// @Test
498498
void whenPolicyIsRetryAndRetryIsSuccessfulThenContainerStarts() throws Exception {
499499
var pulsarClient = PulsarClient.builder()
500500
.serviceUrl(PulsarTestContainerSupport.getPulsarBrokerUrl())

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -478,7 +478,7 @@ void basicDefaultConsumerWithCustomObjectMapper() throws Exception {
478478
@Nested
479479
class WithStartupFailures {
480480

481-
@Test
481+
// @Test
482482
void whenPolicyIsStopThenExceptionIsThrown() {
483483
DefaultPulsarConsumerFactory<String> consumerFactory = mock(DefaultPulsarConsumerFactory.class);
484484
var containerProps = new PulsarContainerProperties();
@@ -502,7 +502,7 @@ void whenPolicyIsStopThenExceptionIsThrown() {
502502
.hasFieldOrPropertyWithValue("container", container)));
503503
}
504504

505-
@Test
505+
// @Test
506506
void whenPolicyIsContinueThenExceptionIsNotThrown() {
507507
DefaultPulsarConsumerFactory<String> consumerFactory = mock(DefaultPulsarConsumerFactory.class);
508508
var containerProps = new PulsarContainerProperties();
@@ -524,7 +524,7 @@ void whenPolicyIsContinueThenExceptionIsNotThrown() {
524524
.hasFieldOrPropertyWithValue("container", container)));
525525
}
526526

527-
@Test
527+
// @Test
528528
void whenPolicyIsRetryAndRetriesAreExhaustedThenContainerDoesNotStart() {
529529
DefaultPulsarConsumerFactory<String> consumerFactory = mock(DefaultPulsarConsumerFactory.class);
530530
var retryCount = new AtomicInteger(0);
@@ -575,7 +575,7 @@ public <T, E extends Throwable> void onError(RetryContext context, RetryCallback
575575
.hasFieldOrPropertyWithValue("container", container)));
576576
}
577577

578-
@Test
578+
// @Test
579579
void whenPolicyIsRetryAndRetryIsSuccessfulThenContainerStarts() throws Exception {
580580
var topic = "dpmlct-wsf-retry";
581581
var pulsarClient = PulsarClient.builder()

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -196,7 +196,7 @@ private void safeStopContainer(PulsarMessageReaderContainer container) {
196196
@Nested
197197
class WithStartupFailures {
198198

199-
@Test
199+
// @Test
200200
void whenPolicyIsStopThenExceptionIsThrown() throws Exception {
201201
DefaultPulsarReaderFactory<String> readerFactory = mock(DefaultPulsarReaderFactory.class);
202202
var containerProps = new PulsarReaderContainerProperties();
@@ -220,7 +220,7 @@ void whenPolicyIsStopThenExceptionIsThrown() throws Exception {
220220
.hasFieldOrPropertyWithValue("container", container)));
221221
}
222222

223-
@Test
223+
// @Test
224224
void whenPolicyIsContinueThenExceptionIsNotThrown() throws Exception {
225225
DefaultPulsarReaderFactory<String> readerFactory = mock(DefaultPulsarReaderFactory.class);
226226
var containerProps = new PulsarReaderContainerProperties();
@@ -242,7 +242,7 @@ void whenPolicyIsContinueThenExceptionIsNotThrown() throws Exception {
242242
.hasFieldOrPropertyWithValue("container", container)));
243243
}
244244

245-
@Test
245+
// @Test
246246
void whenPolicyIsRetryAndRetriesAreExhaustedThenContainerDoesNotStart() throws Exception {
247247
DefaultPulsarReaderFactory<String> readerFactory = mock(DefaultPulsarReaderFactory.class);
248248
var retryCount = new AtomicInteger(0);
@@ -293,7 +293,7 @@ public <T, E extends Throwable> void onError(RetryContext context, RetryCallback
293293
.hasFieldOrPropertyWithValue("container", container)));
294294
}
295295

296-
@Test
296+
// @Test
297297
void whenPolicyIsRetryAndRetryIsSuccessfulThenContainerStarts() throws Exception {
298298
var topic = "dpmlct-wsf-retry";
299299
var readerFactory = spy(new DefaultPulsarReaderFactory<String>(pulsarClient, List.of((readerBuilder) -> {

0 commit comments

Comments
 (0)