diff --git a/pulsar-broker/src/test/java/com/yahoo/pulsar/websocket/proxy/ProxyAuthenticationTest.java b/pulsar-broker/src/test/java/com/yahoo/pulsar/websocket/proxy/ProxyAuthenticationTest.java index 18c5afcbb03404f33094638e4645de9de88ba1fa..5fb752f0390313dd70ca14c46c465eee1f5c5b65 100644 --- a/pulsar-broker/src/test/java/com/yahoo/pulsar/websocket/proxy/ProxyAuthenticationTest.java +++ b/pulsar-broker/src/test/java/com/yahoo/pulsar/websocket/proxy/ProxyAuthenticationTest.java @@ -44,7 +44,7 @@ import com.yahoo.pulsar.websocket.service.WebSocketServiceStarter; public class ProxyAuthenticationTest extends ProducerConsumerBase { protected String methodName; - private static final int TEST_PORT = 6080; + private static final int TEST_PORT = PortManager.nextFreePort(); private static final String CONSUME_URI = "ws://localhost:" + TEST_PORT + "/ws/consumer/persistent/my-property/use/my-ns/my-topic/my-sub"; private static final String PRODUCE_URI = "ws://localhost:" + TEST_PORT diff --git a/pulsar-broker/src/test/java/com/yahoo/pulsar/websocket/proxy/ProxyPublishConsumeTls.java b/pulsar-broker/src/test/java/com/yahoo/pulsar/websocket/proxy/ProxyPublishConsumeTls.java index caf40ac894e59cc75303ac93fee19712d1c13542..404d9c8d69830d71d29e9305bf31530818f9fa1d 100644 --- a/pulsar-broker/src/test/java/com/yahoo/pulsar/websocket/proxy/ProxyPublishConsumeTls.java +++ b/pulsar-broker/src/test/java/com/yahoo/pulsar/websocket/proxy/ProxyPublishConsumeTls.java @@ -29,6 +29,7 @@ import javax.net.ssl.KeyManager; import javax.net.ssl.SSLContext; import javax.net.ssl.TrustManager; +import org.apache.bookkeeper.test.PortManager; import org.eclipse.jetty.util.ssl.SslContextFactory; import org.eclipse.jetty.websocket.api.Session; import org.eclipse.jetty.websocket.client.ClientUpgradeRequest; @@ -50,12 +51,13 @@ import io.netty.handler.ssl.util.InsecureTrustManagerFactory; public class ProxyPublishConsumeTls extends ProducerConsumerBase { protected String methodName; - private static final String CONSUME_URI = "wss://localhost:6090/ws/consumer/persistent/my-property/use/my-ns/my-topic/my-sub"; - private static final String PRODUCE_URI = "wss://localhost:6090/ws/producer/persistent/my-property/use/my-ns/my-topic/"; + private static final int TEST_PORT = PortManager.nextFreePort(); + private static final int TLS_TEST_PORT = PortManager.nextFreePort(); + private static final String CONSUME_URI = "wss://localhost:" + TLS_TEST_PORT + "/ws/consumer/persistent/my-property/use/my-ns/my-topic/my-sub"; + private static final String PRODUCE_URI = "wss://localhost:" + TLS_TEST_PORT + "/ws/producer/persistent/my-property/use/my-ns/my-topic/"; private static final String TLS_SERVER_CERT_FILE_PATH = "./src/test/resources/certificate/server.crt"; - private static final String TLS_SERVER_KEY_FILE_PATH = "./src/test/resources/certificate/server.key"; - private static final int TEST_PORT = 6080; - private static final int TLS_TEST_PORT = 6090; + private static final String TLS_SERVER_KEY_FILE_PATH = "./src/test/resources/certificate/server.key"; + private ProxyServer proxyServer; private WebSocketService service; diff --git a/pulsar-broker/src/test/java/com/yahoo/pulsar/websocket/proxy/ProxyPublishConsumeWithoutZKTest.java b/pulsar-broker/src/test/java/com/yahoo/pulsar/websocket/proxy/ProxyPublishConsumeWithoutZKTest.java index 96d99ce1ef5fa5734e73c0a2a676d50b26e3c2c6..791c53b31ae6a9b82d73a9b27eb012f731507d53 100644 --- a/pulsar-broker/src/test/java/com/yahoo/pulsar/websocket/proxy/ProxyPublishConsumeWithoutZKTest.java +++ b/pulsar-broker/src/test/java/com/yahoo/pulsar/websocket/proxy/ProxyPublishConsumeWithoutZKTest.java @@ -21,6 +21,7 @@ import static org.mockito.Mockito.spy; import java.net.URI; import java.util.concurrent.Future; +import org.apache.bookkeeper.test.PortManager; import org.eclipse.jetty.websocket.api.Session; import org.eclipse.jetty.websocket.client.ClientUpgradeRequest; import org.eclipse.jetty.websocket.client.WebSocketClient; @@ -39,9 +40,9 @@ import com.yahoo.pulsar.websocket.service.WebSocketServiceStarter; public class ProxyPublishConsumeWithoutZKTest extends ProducerConsumerBase { protected String methodName; - private static final String CONSUME_URI = "ws://localhost:6080/ws/consumer/persistent/my-property/use/my-ns/my-topic/my-sub"; - private static final String PRODUCE_URI = "ws://localhost:6080/ws/producer/persistent/my-property/use/my-ns/my-topic/"; - private static final int TEST_PORT = 6080; + private static final int TEST_PORT = PortManager.nextFreePort(); + private static final String CONSUME_URI = "ws://localhost:" + TEST_PORT + "/ws/consumer/persistent/my-property/use/my-ns/my-topic/my-sub"; + private static final String PRODUCE_URI = "ws://localhost:" + TEST_PORT + "/ws/producer/persistent/my-property/use/my-ns/my-topic/"; private ProxyServer proxyServer; private WebSocketService service;