| | |
|---|
| | | * 初始化mqtt客户端 |
|---|
| | | */ |
|---|
| | | public void initMqttClient() { |
|---|
| | | if (MqttRecvClient.getInstance().isConnected()) { |
|---|
| | | //检查断开连接 |
|---|
| | | MqttRecvClient.getInstance().reConnect(); |
|---|
| | | } |
|---|
| | | if (!MqttRecvClient.getInstance().isInit()) { |
|---|
| | | HdlMqttLogic.getInstance().getMqttRemoteInfo(HomeType.A, new CloudCallBeak<MqttInfo>() { |
|---|
| | | @Override |
|---|
| | | public void onSuccess(MqttInfo info) { |
|---|
| | | if (info != null) { |
|---|
| | | MqttRecvClient.getInstance().setConnectParam(info.getUrl(), info.getClientId(), info.getUserName(), info.getPassWord(), null); |
|---|
| | | MqttRecvClient.getInstance().setConnectParam(info.getUrl(), info.getClientId(), info.getUserName(), info.getPassWord()); |
|---|
| | | MqttRecvClient.getInstance().connect(); |
|---|
| | | } |
|---|
| | | } |
|---|
