diff --git a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D314PingMessageExecutor.java b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D314PingMessageExecutor.java index 13eabf10..e25cc341 100644 --- a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D314PingMessageExecutor.java +++ b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/executor/D314PingMessageExecutor.java @@ -5,6 +5,8 @@ import com.imdroid.sideslope.server.DeviceChannel; import com.imdroid.sideslope.server.OnlineChannels; import io.netty.buffer.ByteBuf; import io.netty.buffer.Unpooled; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; /** @@ -13,6 +15,7 @@ import org.springframework.stereotype.Component; */ @Component public class D314PingMessageExecutor implements Executor { + private final Logger logger = LoggerFactory.getLogger(this.getClass()); @Override public Void execute(D314PingMessage message) { @@ -24,6 +27,7 @@ public class D314PingMessageExecutor implements Executor ByteBuf buf = Unpooled.buffer(); buf.writeBytes(forwardBytes); deviceChannel.writeAndFlush(buf); + logger.info("{} ping ack",deviceId); } return null;