diff --git a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java
index 02850e9d8c..8f3b0efc5b 100644
--- a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java
+++ b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java
@@ -608,7 +608,7 @@ public class DefaultTbCoreConsumerService extends AbstractConsumerService<ToCore
             stateService.onDeviceConnect(tenantId, deviceId);
             callback.onSuccess();
         } catch (Exception e) {
-            log.warn("Failed process device connect message for device [{}]", deviceId, e);
+            log.warn("Failed to process device connect message for device [{}]", deviceId, e);
             callback.onFailure(e);
         }
     }
@@ -623,7 +623,7 @@ public class DefaultTbCoreConsumerService extends AbstractConsumerService<ToCore
             stateService.onDeviceActivity(tenantId, deviceId, deviceActivityMsg.getLastActivityTime());
             callback.onSuccess();
         } catch (Exception e) {
-            log.warn("Failed process device activity message for device [{}]", deviceId, e);
+            log.warn("Failed to process device activity message for device [{}]", deviceId, e);
             callback.onFailure(e);
         }
     }
@@ -635,7 +635,7 @@ public class DefaultTbCoreConsumerService extends AbstractConsumerService<ToCore
             stateService.onDeviceDisconnect(tenantId, deviceId);
             callback.onSuccess();
         } catch (Exception e) {
-            log.warn("Failed process device activity message for device [{}]", deviceId, e);
+            log.warn("Failed to process device activity message for device [{}]", deviceId, e);
             callback.onFailure(e);
         }
     }
@@ -647,7 +647,7 @@ public class DefaultTbCoreConsumerService extends AbstractConsumerService<ToCore
             stateService.onDeviceInactivity(tenantId, deviceId);
             callback.onSuccess();
         } catch (Exception e) {
-            log.warn("Failed process device inactivity message for device [{}]", deviceId, e);
+            log.warn("Failed to process device inactivity message for device [{}]", deviceId, e);
             callback.onFailure(e);
         }
     }