diff --git a/broker/src/test/java/io/moquette/server/ServerIntegrationWebSocketTest.java b/broker/src/test/java/io/moquette/server/ServerIntegrationWebSocketTest.java index 3f7de183..c12a062e 100644 --- a/broker/src/test/java/io/moquette/server/ServerIntegrationWebSocketTest.java +++ b/broker/src/test/java/io/moquette/server/ServerIntegrationWebSocketTest.java @@ -71,16 +71,17 @@ public class ServerIntegrationWebSocketTest { @Test public void checkPlainConnect() throws Exception { LOG.info("*** checkPlainConnect ***"); - String destUri = "ws://localhost:" + BrokerConstants.WEBSOCKET_PORT; + String destUri = "ws://localhost:" + BrokerConstants.WEBSOCKET_PORT + "/mqtt"; MQTTWebSocket socket = new MQTTWebSocket(); client.start(); URI echoUri = new URI(destUri); ClientUpgradeRequest request = new ClientUpgradeRequest(); client.connect(socket, echoUri, request); - LOG.info("Connecting to : %s", echoUri); + LOG.info("Connecting to : {}", echoUri); boolean connected = socket.awaitConnected(4, TimeUnit.SECONDS); - + LOG.info("Connected was : {}", connected); + assertTrue(connected); } }