diff --git a/mqtt-spring-boot-starter/src/main/java/io/github/brandonbai/mqtt/MqttAutoConfiguration.java b/mqtt-spring-boot-starter/src/main/java/io/github/brandonbai/mqtt/MqttAutoConfiguration.java index 486fe62..57b934e 100644 --- a/mqtt-spring-boot-starter/src/main/java/io/github/brandonbai/mqtt/MqttAutoConfiguration.java +++ b/mqtt-spring-boot-starter/src/main/java/io/github/brandonbai/mqtt/MqttAutoConfiguration.java @@ -22,8 +22,8 @@ public class MqttAutoConfiguration { public DefaultMqttPahoClientFactory clientFactory() { MqttConnectOptions connectOptions = new MqttConnectOptions(); - connectOptions.setPassword(mqttProperties.getUsername().toCharArray()); - connectOptions.setUserName(mqttProperties.getPassword()); + connectOptions.setPassword(mqttProperties.getPassword()); + connectOptions.setUserName(mqttProperties.getUsername().toCharArray()); connectOptions.setCleanSession(mqttProperties.getCleanSession()); connectOptions.setKeepAliveInterval(mqttProperties.getKeepAliveInterval()); connectOptions.setServerURIs(mqttProperties.getServerURIs());