|
|
|
@ -20,6 +20,7 @@ import org.eclipse.paho.client.mqttv3.MqttException; |
|
|
|
import org.junit.Assert; |
|
|
|
import org.junit.Before; |
|
|
|
import org.junit.Test; |
|
|
|
import org.junit.jupiter.api.Assertions; |
|
|
|
import org.thingsboard.common.util.JacksonUtil; |
|
|
|
import org.thingsboard.server.common.data.Device; |
|
|
|
import org.thingsboard.server.common.data.StringUtils; |
|
|
|
@ -115,7 +116,7 @@ public class BasicMqttCredentialsTest extends AbstractMqttIntegrationTest { |
|
|
|
testTelemetryIsDelivered(accessToken2Device, mqttTestClient5); |
|
|
|
} |
|
|
|
|
|
|
|
@Test(expected = MqttException.class) |
|
|
|
@Test |
|
|
|
public void testCorrectClientIdAndUserNameButWrongPassword() throws Exception { |
|
|
|
// Not correct. Correct clientId and username, but wrong password
|
|
|
|
MqttTestClient mqttTestClient = new MqttTestClient(CLIENT_ID); |
|
|
|
@ -125,7 +126,9 @@ public class BasicMqttCredentialsTest extends AbstractMqttIntegrationTest { |
|
|
|
} catch (MqttException e) { |
|
|
|
Assert.assertEquals(4, e.getReasonCode()); // 4 - Reason code for bad username or password in MQTT v3
|
|
|
|
} |
|
|
|
testTelemetryIsNotDelivered(clientIdAndUserNameAndPasswordDevice3, mqttTestClient); |
|
|
|
Assertions.assertThrows(MqttException.class, () -> { |
|
|
|
testTelemetryIsNotDelivered(clientIdAndUserNameAndPasswordDevice3, mqttTestClient); |
|
|
|
}); |
|
|
|
} |
|
|
|
|
|
|
|
private void testTelemetryIsDelivered(Device device, MqttTestClient client) throws Exception { |
|
|
|
|