From ed611e8f042d1899912c74e00e272d14dc7dffc1 Mon Sep 17 00:00:00 2001 From: Volodymyr Babak Date: Wed, 28 Sep 2022 13:26:45 +0300 Subject: [PATCH] Typo fix --- .../server/service/edge/DefaultEdgeNotificationService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/application/src/main/java/org/thingsboard/server/service/edge/DefaultEdgeNotificationService.java b/application/src/main/java/org/thingsboard/server/service/edge/DefaultEdgeNotificationService.java index 9cbb7d5de8..f1a6af6b7c 100644 --- a/application/src/main/java/org/thingsboard/server/service/edge/DefaultEdgeNotificationService.java +++ b/application/src/main/java/org/thingsboard/server/service/edge/DefaultEdgeNotificationService.java @@ -112,7 +112,7 @@ public class DefaultEdgeNotificationService implements EdgeNotificationService { private WidgetTypeEdgeProcessor widgetTypeProcessor; @Autowired - private QueueEdgeProcessor queueEdgeProcessor; + private QueueEdgeProcessor queueProcessor; @Autowired private AlarmEdgeProcessor alarmProcessor; @@ -204,7 +204,7 @@ public class DefaultEdgeNotificationService implements EdgeNotificationService { future = widgetTypeProcessor.processWidgetTypeNotification(tenantId, edgeNotificationMsg); break; case QUEUE: - future = queueEdgeProcessor.processQueueNotification(tenantId, edgeNotificationMsg); + future = queueProcessor.processQueueNotification(tenantId, edgeNotificationMsg); break; case ALARM: future = alarmProcessor.processAlarmNotification(tenantId, edgeNotificationMsg);