From 6b5b654546fb5b49446c0fccc1eb53eff36bff91 Mon Sep 17 00:00:00 2001
From: Dmytro Skarzhynets <dskarzhynets@thingsboard.io>
Date: Tue, 12 Sep 2023 13:42:18 +0300
Subject: [PATCH] Fix grammar

---
 .../service/queue/DefaultTbCoreConsumerService.java       | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

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);
         }
     }