From 8be9303973eecc7ebc68280ba48c3f7771601449 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Mon, 21 Jun 2021 10:48:37 -0400 Subject: [PATCH] Disable ZeroMQ PUB/SUB tests --- .../cloud/stream/app/sink/zeromq/ZeroMqSinkTests.java | 2 ++ .../fn/consumer/zeromq/ZeroMqConsumerConfigurationTests.java | 2 ++ 2 files changed, 4 insertions(+) diff --git a/applications/sink/zeromq-sink/src/test/java/org/springframework/cloud/stream/app/sink/zeromq/ZeroMqSinkTests.java b/applications/sink/zeromq-sink/src/test/java/org/springframework/cloud/stream/app/sink/zeromq/ZeroMqSinkTests.java index b0609998..140c4e17 100644 --- a/applications/sink/zeromq-sink/src/test/java/org/springframework/cloud/stream/app/sink/zeromq/ZeroMqSinkTests.java +++ b/applications/sink/zeromq-sink/src/test/java/org/springframework/cloud/stream/app/sink/zeromq/ZeroMqSinkTests.java @@ -17,6 +17,7 @@ package org.springframework.cloud.stream.app.sink.zeromq; import org.junit.jupiter.api.AfterAll; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.zeromq.SocketType; import org.zeromq.ZContext; @@ -44,6 +45,7 @@ import static org.assertj.core.api.Assertions.assertThat; * * @since 3.1.0 */ +@Disabled("PUB/SUB is async and we can't guess when subscriber is ready before sending a message") public class ZeroMqSinkTests { private static final ZContext CONTEXT = new ZContext(); diff --git a/functions/consumer/zeromq-consumer/src/test/java/org/springframework/cloud/fn/consumer/zeromq/ZeroMqConsumerConfigurationTests.java b/functions/consumer/zeromq-consumer/src/test/java/org/springframework/cloud/fn/consumer/zeromq/ZeroMqConsumerConfigurationTests.java index 7224275b..9152930f 100644 --- a/functions/consumer/zeromq-consumer/src/test/java/org/springframework/cloud/fn/consumer/zeromq/ZeroMqConsumerConfigurationTests.java +++ b/functions/consumer/zeromq-consumer/src/test/java/org/springframework/cloud/fn/consumer/zeromq/ZeroMqConsumerConfigurationTests.java @@ -20,6 +20,7 @@ import java.util.function.Function; import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.BeforeAll; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.zeromq.SocketType; import org.zeromq.ZContext; @@ -44,6 +45,7 @@ import static org.assertj.core.api.Assertions.assertThat; */ @SpringBootTest(properties = "zeromq.consumer.topic='test-topic'") @DirtiesContext +@Disabled("PUB/SUB is async and we can't guess when subscriber is ready before sending a message") public class ZeroMqConsumerConfigurationTests { private static final ZContext CONTEXT = new ZContext();