| | |
| | | //发送数据 |
| | | myGateway.Send(sendTopic, sendData); |
| | | |
| | | //超时时间 |
| | | int TimeOut = 0; |
| | | waitTime = 20 * waitTime; |
| | | while (listCheckTopic.Count != listReceiptTopic.Count && TimeOut < waitTime) |
| | | { |
| | | //全部接收才退出 |
| | | System.Threading.Thread.Sleep(50); |
| | | TimeOut++; |
| | | } |
| | | myGateway.Actions -= receiptAction; |
| | | receiptAction = null; |
| | | |
| | | int receveCount = listCheckTopic.Count; |
| | | if (receveCount > 1) |
| | | { |
| | |
| | | receveCount = listTemp.Count; |
| | | } |
| | | |
| | | //超时时间 |
| | | int TimeOut = 0; |
| | | waitTime = 20 * waitTime; |
| | | while (receveCount != listReceiptTopic.Count && TimeOut < waitTime) |
| | | { |
| | | //全部接收才退出 |
| | | System.Threading.Thread.Sleep(50); |
| | | TimeOut++; |
| | | } |
| | | myGateway.Actions -= receiptAction; |
| | | receiptAction = null; |
| | | if (receveCount != listReceiptTopic.Count) |
| | | { |
| | | reResult.ErrorMsgDiv = 0; |