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 10719e4c..28158e77 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
@@ -117,9 +117,6 @@ public class D331RtcmMessageExecutor implements Executor<D331RtcmMessage, Void>
                         ByteBuf buf = Unpooled.buffer();
                         buf.writeBytes(forwardBytes);
                         deviceChannel.writeAndFlush(buf);
-                if(deviceChannel != null && deviceChannel.isOnline()) {
-                    if (logger.isDebugEnabled()) {
-                        logger.debug("forward d331 rtcm from {} to device {}", id, deviceId);
                     }
                 } else if (baseStationModel == 0) {
                     //logger.info("Base station model is 0 for device: {}", deviceId);
@@ -298,6 +295,11 @@ public class D331RtcmMessageExecutor implements Executor<D331RtcmMessage, Void>
         return null;
     }
 
+    @Override
+    public Class<?> getMessageType() {
+        return D331RtcmMessage.class;
+    }
+
     private void sendToNtrip(String mountpoint, String hexData) {
         try {
 
@@ -332,5 +334,4 @@ public class D331RtcmMessageExecutor implements Executor<D331RtcmMessage, Void>
                 baseStation.getLastRxTime().isAfter(now.minusMinutes(30));
     }
 
-
 }