diff --git a/application/src/main/java/org/thingsboard/server/service/queue/TbCoreConsumerStats.java b/application/src/main/java/org/thingsboard/server/service/queue/TbCoreConsumerStats.java
index 5ff72e97e3..b7f1147ec0 100644
--- a/application/src/main/java/org/thingsboard/server/service/queue/TbCoreConsumerStats.java
+++ b/application/src/main/java/org/thingsboard/server/service/queue/TbCoreConsumerStats.java
@@ -174,16 +174,10 @@ public class TbCoreConsumerStats {
             toCoreNfComponentLifecycleCounter.increment();
         } else if (msg.hasEdgeEventUpdate()) {
             toCoreNfEdgeEventUpdateCounter.increment();
-        } else if (!msg.getEdgeEventUpdateMsg().isEmpty()) {
-            toCoreNfEdgeEventUpdateCounter.increment();
         } else if (msg.hasToEdgeSyncRequest()) {
             toCoreNfEdgeSyncRequestCounter.increment();
-        } else if (!msg.getToEdgeSyncRequestMsg().isEmpty()) {
-            toCoreNfEdgeSyncRequestCounter.increment();
         } else if (msg.hasFromEdgeSyncResponse()) {
             toCoreNfEdgeSyncResponseCounter.increment();
-        } else if (!msg.getFromEdgeSyncResponseMsg().isEmpty()) {
-            toCoreNfEdgeSyncResponseCounter.increment();
         } else if (msg.hasQueueUpdateMsg()) {
             toCoreNfQueueUpdateCounter.increment();
         } else if (msg.hasQueueDeleteMsg()) {