forked from uav/ard-uav-server
blame | history | patch | commit | commitdiff | ignore whitespace
zhaowenyu
2025-12-09 a0741df5a2cff792740d7d31f7101ba2339ba3ec 
 ard-sample/src/main/java/com/ard/sample/component/mqtt/handler/StateRouter.java


@@ -5,6 +5,7 @@


import com.ard.sample.manage.model.receiver.DeviceBasicReceiver;


import com.ard.sample.manage.model.receiver.FirmwareVersionReceiver;


import com.ard.sample.manage.model.receiver.LiveCapacityReceiver;


import com.ard.sample.manage.model.receiver.LiveStatusTwoReceiver;


import com.fasterxml.jackson.databind.ObjectMapper;


import com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException;


import lombok.extern.slf4j.Slf4j;


@@ -94,10 +95,14 @@


        // Channel mapping for live streaming capabilities.


        router.setChannelMapping(LiveCapacityReceiver.class.getName(),


                ChannelName.INBOUND_STATE_CAPACITY);


        router.setChannelMapping(LiveStatusTwoReceiver.class.getName(),


                ChannelName.INBOUND_STATE_STATUS);


        router.setChannelMapping(FirmwareVersionReceiver.class.getName(),


                ChannelName.INBOUND_STATE_FIRMWARE_VERSION);


        router.setChannelMapping(Map.class.getName(),


                ChannelName.DEFAULT);


        // 配置默认输出通道（兜底）


        router.setDefaultOutputChannelName(ChannelName.DEFAULT);


        return router;


    }