| | |
| | | */ |
| | | static MqttClientOptions getBasicClientOptions() { |
| | | if (!mqtt.containsKey(MqttUseEnum.BASIC)) { |
| | | throw new Error("Please configure the basic mqtt connection parameters first, otherwise application cannot be started."); |
| | | throw new Error("请先配置基本的mqtt连接参数,否则应用程序无法启动。"); |
| | | } |
| | | return mqtt.get(MqttUseEnum.BASIC); |
| | | } |
| | |
| | | |
| | | return MqttBrokerDTO.builder() |
| | | .address(getMqttAddress(mqtt.get(MqttUseEnum.DRC))) |
| | | .username(username) |
| | | .username("root") |
| | | .clientId(clientId) |
| | | .expireTime(System.currentTimeMillis() / 1000 + age) |
| | | .password(token) |
| | | .password("root") |
| | | .build(); |
| | | } |
| | | |