| package com.dy.common.mw.protocol4Mqtt; | 
|   | 
| import com.dy.common.util.Callback; | 
|   | 
| /** | 
|  * @Author: liurunyu | 
|  * @Date: 2025/6/5 11:44 | 
|  * @Description | 
|  */ | 
|   | 
| public abstract class MqttSubMsg { | 
|     public String commandId ;//命令ID | 
|     public String mqttResultSendWebUrl ;//Mtt返回命令结果 发向目的地web URL | 
|   | 
|     public String deviceId ;//设备ID | 
|     public String protocol;//协议 | 
|   | 
|     public MqttTopic topic ;//消息主题 | 
|     public String metaData;//MQTT推送来的元数据 | 
|   | 
|     public abstract boolean valid(); | 
|   | 
|     public abstract boolean subMsgMatchPubMsg(MqttPubMsg pubMsg); | 
|   | 
|     public abstract void action(Callback callback); | 
| } |