修复mqtt client 用户密码错误

This commit is contained in:
zhou-hao 2020-11-04 16:28:22 +08:00
parent 7c76bbdbd6
commit 91915a85dd
1 changed files with 2 additions and 2 deletions

View File

@ -113,8 +113,8 @@ public class MqttClientProvider implements NetworkProvider<MqttClientProperties>
: ExpressionUtils.analytical(String.valueOf(config.getPassword()), ctx, "spel");
config.getOptions().setClientId(clientId);
config.getOptions().setPassword(username);
config.getOptions().setUsername(password);
config.getOptions().setPassword(password);
config.getOptions().setUsername(username);
if (config.isSsl()) {
config.getOptions().setSsl(true);