Spring/spring-pulsar
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Disable flaky ReactivePulsarListenerTombstoneTests

Browse Source 
See #561
This commit is contained in:
Chris Bono
2024-05-07 09:20:58 -05:00
parent e7f31ae334
commit 118f7be5aa
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-pulsar-reactive/src/test/java/org/springframework/pulsar/reactive/listener/ReactivePulsarListenerTombstoneTests.java
View File

@@ -29,6 +29,7 @@ import org.apache.pulsar.client.api.PulsarClientException;
import org.apache.pulsar.client.api.Schema;
import org.apache.pulsar.common.schema.SchemaType;
import org.apache.pulsar.reactive.client.api.MessageResult;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Nested;
import org.junit.jupiter.api.Test;
@@ -237,6 +238,7 @@ class ReactivePulsarListenerTombstoneTests extends ReactivePulsarListenerTestsBa
static List<ReceivedMessage<Foo>> receivedMessagesWithoutHeaders = new ArrayList<>();
@Test
@Disabled("Flaky -> see https://github.com/spring-projects/spring-pulsar/issues/561")
void shouldReceiveMessagesWithTombstone() throws Exception {
var pulsarProducerFactory = new DefaultPulsarProducerFactory<Foo>(pulsarClient);
var fooPulsarTemplate = new PulsarTemplate<>(pulsarProducerFactory);