File tree Expand file tree Collapse file tree 1 file changed +0
-14
lines changed
tests/src/test/java/io/streamnative/pulsar/handlers/mqtt/mqtt3/fusesource/base Expand file tree Collapse file tree 1 file changed +0
-14
lines changed Original file line number Diff line number Diff line change @@ -91,20 +91,6 @@ public void testSimpleMqttPubAndSubQos0(String topicName) throws Exception {
9191 connection .disconnect ();
9292 }
9393
94- // @Test(timeOut = TIMEOUT)
95- // public void testInvalidClientId() throws Exception {
96- // MQTT mqtt = createMQTTClient();
97- // mqtt.setClientId("7e8dae24-33c9-41f7-af10-334c4480348b_mqtt-test-6c8b");
98- // BlockingConnection connection = mqtt.blockingConnection();
99- // try {
100- // connection.connect();
101- // Assert.fail();
102- // } catch (Exception exception) {
103- // log.info("Expected exception: {}", exception.getMessage());
104- // }
105- // connection.disconnect();
106- // }
107-
10894 @ Test (dataProvider = "mqttTopicNames" , timeOut = TIMEOUT )
10995 public void testSimpleMqttPubAndSubQos1 (String topicName ) throws Exception {
11096 MQTT mqtt = createMQTTClient ();
You can’t perform that action at this time.
0 commit comments