增加pppoe状态上报
This commit is contained in:
@@ -79,6 +79,8 @@ public enum MsgEnum {
|
|||||||
|
|
||||||
修改frp配置文件应答("UPDATE_FRP_RSP"),
|
修改frp配置文件应答("UPDATE_FRP_RSP"),
|
||||||
|
|
||||||
|
macvlan状态上报("MACVLAN_STATUS_RSP"),
|
||||||
|
|
||||||
多网IP探测上报("NETWORK_DETECT");
|
多网IP探测上报("NETWORK_DETECT");
|
||||||
|
|
||||||
private String value;
|
private String value;
|
||||||
|
|||||||
@@ -427,6 +427,19 @@ public class AgentEndpoint {
|
|||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@AgentDispatcher(msgId = MsgEnum.macvlan状态上报)
|
||||||
|
public class upMacvlanStatusHandler implements AgentHandler {
|
||||||
|
@Override
|
||||||
|
public UpMsgResponse upHandle(String data, String clientId) {
|
||||||
|
JSONObject jsonObject = new JSONObject();
|
||||||
|
jsonObject.put("clientId", clientId);
|
||||||
|
jsonObject.put("dataType", MsgEnum.macvlan状态上报.getValue());
|
||||||
|
jsonObject.put("data", data);
|
||||||
|
MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
|
||||||
|
agentProducer.asyncSend(mqMsg);
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user