From 78514bb36cfa6d3dbcf708e3358e0f5578c59793 Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Tue, 29 Oct 2019 16:12:59 -0400
Subject: [PATCH] Ignore Kinesis tests when no local Kinesis

---
 ...StreamKinesisToWebfluxApplicationTests.java | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)

diff --git a/kinesis-samples/kinesis-to-webflux/src/test/java/kinesis/webflux/CloudStreamKinesisToWebfluxApplicationTests.java b/kinesis-samples/kinesis-to-webflux/src/test/java/kinesis/webflux/CloudStreamKinesisToWebfluxApplicationTests.java
index 4867f21..ea7d273 100644
--- a/kinesis-samples/kinesis-to-webflux/src/test/java/kinesis/webflux/CloudStreamKinesisToWebfluxApplicationTests.java
+++ b/kinesis-samples/kinesis-to-webflux/src/test/java/kinesis/webflux/CloudStreamKinesisToWebfluxApplicationTests.java
@@ -16,10 +16,14 @@
 
 package kinesis.webflux;
 
+import static org.assertj.core.api.Assumptions.assumeThat;
+
+import java.net.Socket;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.function.Supplier;
 
+import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
 
 import org.springframework.beans.factory.annotation.Autowired;
@@ -67,6 +71,20 @@ public class CloudStreamKinesisToWebfluxApplicationTests {
 	@Autowired
 	private KinesisTestConfiguration kinesisTestConfiguration;
 
+	@BeforeAll
+	static void setup() {
+		boolean isLocalKinesis;
+		try {
+			new Socket("localhost", KinesisTestConfiguration.DEFAULT_KINESALITE_PORT).close();
+			// Successful connection means local Kinesis is available
+			isLocalKinesis = true;
+		}
+		catch (Exception e) {
+			isLocalKinesis  = false;
+		}
+		assumeThat(isLocalKinesis).isTrue();
+	}
+
 	@Test
 	void testKinesisToWebFlux() {
 		this.kinesisTestConfiguration.eventQueue.offer("foo");