| | |
| | | while(node != null && node.obj != null){ |
| | | obj = (MqttPubMsgNode)node.obj; |
| | | pubMsg = obj.result ; |
| | | if(pubMsg != null |
| | | if(!obj.onceReceivedResult |
| | | && pubMsg != null |
| | | && subMsg.subMsgMatchPubMsg(pubMsg)){ |
| | | obj.onceReceivedResult = true ;//标识已经收到命令结果 |
| | | return pubMsg; |
| | |
| | | while(node != null && node.obj != null){ |
| | | obj = (MqttPubMsgNode)node.obj; |
| | | pubMsg = obj.result ; |
| | | if(pubMsg != null && subMsg.subMsgMatchPubMsg(pubMsg)){ |
| | | if(!obj.onceReceivedResult |
| | | && pubMsg != null |
| | | && subMsg.subMsgMatchPubMsg(pubMsg)){ |
| | | obj.onceReceivedResult = true ;//标识已经收到命令结果 |
| | | return pubMsg; |
| | | }else{ |