From 9bdd41e6574fbe69f576cbac5ea9a96b3a7c390c Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Mon, 21 Dec 2020 11:57:55 +0100 Subject: [PATCH] Fix RSocket samples test --- .../java/io/spring/cloudevent/DemoApplicationTests.java | 8 ++++++-- .../java/io/spring/cloudevent/DemoApplicationTests.java | 8 ++++++-- 2 files changed, 12 insertions(+), 4 deletions(-) diff --git a/spring-cloud-function-samples/function-sample-cloudevent-rsocket/src/test/java/io/spring/cloudevent/DemoApplicationTests.java b/spring-cloud-function-samples/function-sample-cloudevent-rsocket/src/test/java/io/spring/cloudevent/DemoApplicationTests.java index 90358ace5..e09a46408 100644 --- a/spring-cloud-function-samples/function-sample-cloudevent-rsocket/src/test/java/io/spring/cloudevent/DemoApplicationTests.java +++ b/spring-cloud-function-samples/function-sample-cloudevent-rsocket/src/test/java/io/spring/cloudevent/DemoApplicationTests.java @@ -1,5 +1,7 @@ package io.spring.cloudevent; +import java.net.InetSocketAddress; +import java.net.Socket; import java.util.Collections; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.TimeUnit; @@ -64,11 +66,13 @@ public class DemoApplicationTests { @Override public ConditionEvaluationResult evaluateExecutionCondition(ExtensionContext context) { try { - KafkaAdminClient.create(Collections.singletonMap("bootstrap.servers", "localhost:9092")); + Socket socket = new Socket(); + socket.connect(new InetSocketAddress("localhost", 9092)); + socket.close(); } catch (Exception e) { System.out.println("Kafka is not available on localhost:9092"); - return ConditionEvaluationResult.enabled("Kafka is not available on localhost, default port"); + return ConditionEvaluationResult.disabled("Kafka is not available on localhost, default port"); } return ConditionEvaluationResult.enabled("All is good"); diff --git a/spring-cloud-function-samples/function-sample-cloudevent-stream/src/test/java/io/spring/cloudevent/DemoApplicationTests.java b/spring-cloud-function-samples/function-sample-cloudevent-stream/src/test/java/io/spring/cloudevent/DemoApplicationTests.java index c2ec6e012..eb57b7bc6 100644 --- a/spring-cloud-function-samples/function-sample-cloudevent-stream/src/test/java/io/spring/cloudevent/DemoApplicationTests.java +++ b/spring-cloud-function-samples/function-sample-cloudevent-stream/src/test/java/io/spring/cloudevent/DemoApplicationTests.java @@ -1,5 +1,7 @@ package io.spring.cloudevent; +import java.net.InetSocketAddress; +import java.net.Socket; import java.util.Collections; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.TimeUnit; @@ -60,11 +62,13 @@ public class DemoApplicationTests { try { new CachingConnectionFactory("localhost").createConnection(); try { - KafkaAdminClient.create(Collections.singletonMap("bootstrap.servers", "localhost:9092")); + Socket socket = new Socket(); + socket.connect(new InetSocketAddress("localhost", 9092)); + socket.close(); } catch (Exception e) { System.out.println("Kafka is not available on localhost:9092"); - return ConditionEvaluationResult.enabled("Kafka is not available on localhost, default port"); + return ConditionEvaluationResult.disabled("Kafka is not available on localhost, default port"); } } catch (Exception e) {