From 94f3dcc03feea784ab7e82885ec207694665a966 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Fri, 5 Feb 2021 10:19:49 -0500 Subject: [PATCH] Disable some tests temporarily --- .../cloud/stream/app/mqtt/sink/MqttSinkTests.java | 2 ++ .../cloud/stream/app/sink/rabbit/OwnConnectionTest.java | 2 ++ .../app/sink/rabbit/SimpleRoutingKeyAndCustomHeaderTests.java | 2 ++ 3 files changed, 6 insertions(+) diff --git a/applications/sink/mqtt-sink/src/test/java/org/springframework/cloud/stream/app/mqtt/sink/MqttSinkTests.java b/applications/sink/mqtt-sink/src/test/java/org/springframework/cloud/stream/app/mqtt/sink/MqttSinkTests.java index 6a718998..ade953d6 100644 --- a/applications/sink/mqtt-sink/src/test/java/org/springframework/cloud/stream/app/mqtt/sink/MqttSinkTests.java +++ b/applications/sink/mqtt-sink/src/test/java/org/springframework/cloud/stream/app/mqtt/sink/MqttSinkTests.java @@ -17,6 +17,7 @@ package org.springframework.cloud.stream.app.mqtt.sink; import org.junit.jupiter.api.AfterAll; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.testcontainers.containers.GenericContainer; @@ -56,6 +57,7 @@ public class MqttSinkTests { } @Test + @Disabled public void testMqttSink() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration diff --git a/applications/sink/rabbit-sink/src/test/java/org/springframework/cloud/stream/app/sink/rabbit/OwnConnectionTest.java b/applications/sink/rabbit-sink/src/test/java/org/springframework/cloud/stream/app/sink/rabbit/OwnConnectionTest.java index d6680795..c2e3aef5 100644 --- a/applications/sink/rabbit-sink/src/test/java/org/springframework/cloud/stream/app/sink/rabbit/OwnConnectionTest.java +++ b/applications/sink/rabbit-sink/src/test/java/org/springframework/cloud/stream/app/sink/rabbit/OwnConnectionTest.java @@ -16,6 +16,7 @@ package org.springframework.cloud.stream.app.sink.rabbit; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.springframework.amqp.core.Message; @@ -30,6 +31,7 @@ import static org.assertj.core.api.Assertions.assertThat; public class OwnConnectionTest extends RabbitSinkIntegrationTests { @Test + @Disabled public void test() { this.rabbitAdmin.declareQueue( new Queue("scsapp-testOwn", false, false, true)); diff --git a/applications/sink/rabbit-sink/src/test/java/org/springframework/cloud/stream/app/sink/rabbit/SimpleRoutingKeyAndCustomHeaderTests.java b/applications/sink/rabbit-sink/src/test/java/org/springframework/cloud/stream/app/sink/rabbit/SimpleRoutingKeyAndCustomHeaderTests.java index 4450c9bf..29df4a3f 100644 --- a/applications/sink/rabbit-sink/src/test/java/org/springframework/cloud/stream/app/sink/rabbit/SimpleRoutingKeyAndCustomHeaderTests.java +++ b/applications/sink/rabbit-sink/src/test/java/org/springframework/cloud/stream/app/sink/rabbit/SimpleRoutingKeyAndCustomHeaderTests.java @@ -16,6 +16,7 @@ package org.springframework.cloud.stream.app.sink.rabbit; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.springframework.amqp.core.Message; @@ -31,6 +32,7 @@ import static org.assertj.core.api.Assertions.assertThat; public class SimpleRoutingKeyAndCustomHeaderTests extends RabbitSinkIntegrationTests { @Test + @Disabled public void test() { this.channels.send(MessageBuilder.withPayload("foo".getBytes()) .setHeader("bar", "baz")