diff --git a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java index c4d6f89d..06798d52 100644 --- a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java +++ b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D331RtcmMessageExecutor.java @@ -287,7 +287,12 @@ public class D331RtcmMessageExecutor implements Executor logger.info("Device {} not enabled for TCP forwarding", deviceId); return; } - + Optional.ofNullable(RtcmGgaUtil.getRtcms(hexData)) + .ifPresent(rtcm -> { + //System.out.println("挂载点: " + mountpoint); + //System.out.println("RTCM数据: " + rtcm); + ntripServer.send(deviceId, rtcm); + }); try { // 添加原始数据日志 logger.info("Processing hex data for device {}, data length: {}", deviceId, hexData.length());