From 269b955fb1c50e5497a1b4a1dfd2884b49c5fc61 Mon Sep 17 00:00:00 2001 From: Spencer Gibb Date: Fri, 17 Mar 2017 11:33:49 -0600 Subject: [PATCH] fix test that fails with port already in use error --- .../launcher/kafka/DeployerApplicationTests.java | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/spring-cloud-launcher/spring-cloud-launcher-kafka/src/test/java/org/springframework/cloud/launcher/kafka/DeployerApplicationTests.java b/spring-cloud-launcher/spring-cloud-launcher-kafka/src/test/java/org/springframework/cloud/launcher/kafka/DeployerApplicationTests.java index c6d16bd..2b0c04b 100644 --- a/spring-cloud-launcher/spring-cloud-launcher-kafka/src/test/java/org/springframework/cloud/launcher/kafka/DeployerApplicationTests.java +++ b/spring-cloud-launcher/spring-cloud-launcher-kafka/src/test/java/org/springframework/cloud/launcher/kafka/DeployerApplicationTests.java @@ -1,14 +1,29 @@ package org.springframework.cloud.launcher.kafka; +import org.junit.AfterClass; +import org.junit.BeforeClass; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner; +import org.springframework.util.SocketUtils; @RunWith(SpringRunner.class) @SpringBootTest public class DeployerApplicationTests { + @BeforeClass + public static void before() { + System.setProperty("kafka.port", String.valueOf(SocketUtils.findAvailableTcpPort())); + System.setProperty("zk.port", String.valueOf(SocketUtils.findAvailableTcpPort())); + } + + @AfterClass + public static void after() { + System.clearProperty("kafka.port"); + System.clearProperty("zk.port"); + } + @Test public void contextLoads() { }