| | |
|---|
| | | connOpts.setMqttVersion(MqttConnectOptions.MQTT_VERSION_3_1_1);
|
|---|
| | | sampleClient.setCallback(new MqttCallbackExtended() {
|
|---|
| | | public void connectComplete(boolean reconnect, String serverURI) {
|
|---|
| | | LogUtils.d(TAG, "connect success");
|
|---|
| | | LogUtils.d(TAG, "mqtt连接成功");
|
|---|
| | | checkAndsubscribeAllTopics("");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public void connectionLost(Throwable throwable) {
|
|---|
| | | LogUtils.d(TAG, "连接断开");
|
|---|
| | | LogUtils.d(TAG, "mqtt连接断开");
|
|---|
| | | lastTopicFilters.clear();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|---|
| | | if (cloudsGatewayId.equals(HDLLinkConfig.getInstance().getHomeId())) {
|
|---|
| | | aes = getHomeAES();
|
|---|
| | | } else if (gatewayBean != null && HDLConnectHelper.getGatewayTypeList().contains(gatewayBean.getGatewayType())) {
|
|---|
| | | //毫米波mqtt专用秘钥
|
|---|
| | | //逆变器mqtt专用秘钥
|
|---|
| | | aes = gatewayBean.getAesKey();
|
|---|
| | | } else {
|
|---|
| | | aes = HDLLinkConfig.getInstance().getAesKey();
|
|---|
