Refactor EdgeContextComponent map

application/src/main/java/org/thingsboard/server/service/edge/EdgeContextComponent.java

@@ -16,6 +16,7 @@
 package org.thingsboard.server.service.edge;
 
 import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
@@ -87,50 +88,29 @@ import org.thingsboard.server.service.edge.rpc.processor.widget.WidgetTypeEdgePr
 import org.thingsboard.server.service.edge.rpc.sync.EdgeRequestsService;
 import org.thingsboard.server.service.executors.GrpcCallbackExecutorService;
 
-import javax.annotation.PostConstruct;
-import java.util.Collections;
-import java.util.HashMap;
+import java.util.EnumMap;
+import java.util.List;
 import java.util.Map;
 
 @Lazy
 @Data
+@Slf4j
 @Component
 @TbCoreComponent
 public class EdgeContextComponent {
 
-    private Map<EdgeEventType, EdgeProcessor> processorMap;
-
-    @PostConstruct
-    private void initProcessorMap() {
-        Map<EdgeEventType, EdgeProcessor> map = new HashMap<>();
-        map.put(EdgeEventType.ADMIN_SETTINGS, adminSettingsProcessor);
-        map.put(EdgeEventType.ALARM, alarmProcessor);
-        map.put(EdgeEventType.ALARM_COMMENT, alarmCommentProcessor);
-        map.put(EdgeEventType.ASSET, assetProcessor);
-        map.put(EdgeEventType.ASSET_PROFILE, assetProfileProcessor);
-        map.put(EdgeEventType.CUSTOMER, customerProcessor);
-        map.put(EdgeEventType.DASHBOARD, dashboardProcessor);
-        map.put(EdgeEventType.DEVICE, deviceProcessor);
-        map.put(EdgeEventType.DEVICE_PROFILE, deviceProfileProcessor);
-        map.put(EdgeEventType.DOMAIN, domainProcessor);
-        map.put(EdgeEventType.EDGE, edgeEntityProcessor);
-        map.put(EdgeEventType.ENTITY_VIEW, entityViewProcessor);
-        map.put(EdgeEventType.NOTIFICATION_RULE, notificationRuleProcessor);
-        map.put(EdgeEventType.NOTIFICATION_TARGET, notificationTargetProcessor);
-        map.put(EdgeEventType.NOTIFICATION_TEMPLATE, notificationTemplateProcessor);
-        map.put(EdgeEventType.OAUTH2_CLIENT, oAuth2ClientProcessor);
-        map.put(EdgeEventType.OTA_PACKAGE, otaPackageProcessor);
-        map.put(EdgeEventType.QUEUE, queueProcessor);
-        map.put(EdgeEventType.RELATION, relationProcessor);
-        map.put(EdgeEventType.RULE_CHAIN, ruleChainProcessor);
-        map.put(EdgeEventType.RULE_CHAIN_METADATA, ruleChainMetadataProcessor);
-        map.put(EdgeEventType.TB_RESOURCE, resourceProcessor);
-        map.put(EdgeEventType.TENANT, tenantProcessor);
-        map.put(EdgeEventType.TENANT_PROFILE, tenantProfileProcessor);
-        map.put(EdgeEventType.USER, userProcessor);
-        map.put(EdgeEventType.WIDGETS_BUNDLE, widgetBundleProcessor);
-        map.put(EdgeEventType.WIDGET_TYPE, widgetTypeProcessor);
-        this.processorMap = Collections.unmodifiableMap(map);
+    private final Map<EdgeEventType, EdgeProcessor> processorMap = new EnumMap<>(EdgeEventType.class);
+
+    @Autowired
+    public EdgeContextComponent(List<EdgeProcessor> processors) {
+        processors.forEach(processor -> {
+            EdgeEventType eventType = processor.getEdgeEventType();
+            if (eventType != null) {
+                processorMap.put(eventType, processor);
+            } else {
+                log.warn("Processor {} does not specify a supported EdgeEventType", processor.getClass().getSimpleName());
+            }
+        });
     }
 
     // services

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/BaseEdgeProcessor.java

@@ -20,6 +20,7 @@ import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Lazy;
 import org.thingsboard.common.util.JacksonUtil;
 import org.thingsboard.server.common.data.AttributeScope;
 import org.thingsboard.server.common.data.EdgeUtils;
@@ -75,6 +76,7 @@ public abstract class BaseEdgeProcessor implements EdgeProcessor {
     protected static final Lock deviceCreationLock = new ReentrantLock();
     protected static final Lock assetCreationLock = new ReentrantLock();
 
+    @Lazy
     @Autowired
     protected EdgeContextComponent edgeCtx;
 

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/EdgeProcessor.java

@@ -17,6 +17,7 @@ package org.thingsboard.server.service.edge.rpc.processor;
 
 import com.google.common.util.concurrent.ListenableFuture;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.TenantId;
 import org.thingsboard.server.gen.edge.v1.DownlinkMsg;
 import org.thingsboard.server.gen.transport.TransportProtos;
@@ -29,4 +30,8 @@ public interface EdgeProcessor {
         return null;
     }
 
+    default EdgeEventType getEdgeEventType() {
+        return null;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/alarm/AlarmEdgeProcessor.java

@@ -115,4 +115,9 @@ public class AlarmEdgeProcessor extends BaseAlarmProcessor implements AlarmProce
         return null;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.ALARM;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/alarm/comment/AlarmCommentEdgeProcessor.java

@@ -90,4 +90,9 @@ public class AlarmCommentEdgeProcessor extends BaseAlarmProcessor implements Ala
         return Futures.transform(Futures.allAsList(delFutures), voids -> null, dbCallbackExecutorService);
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.ALARM_COMMENT;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/asset/AssetEdgeProcessor.java

@@ -141,4 +141,9 @@ public class AssetEdgeProcessor extends BaseAssetProcessor implements AssetProce
         asset.setCustomerId(customerUUID);
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.ASSET;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/asset/profile/AssetProfileEdgeProcessor.java

@@ -136,4 +136,9 @@ public class AssetProfileEdgeProcessor extends BaseAssetProfileProcessor impleme
         assetProfile.setDefaultDashboardId(defaultDashboardUUID != null ? new DashboardId(defaultDashboardUUID) : null);
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.ASSET_PROFILE;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/customer/CustomerEdgeProcessor.java

@@ -95,4 +95,9 @@ public class CustomerEdgeProcessor extends BaseEdgeProcessor {
         }
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.CUSTOMER;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/dashboard/DashboardEdgeProcessor.java

@@ -25,6 +25,7 @@ import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.ShortCustomerInfo;
 import org.thingsboard.server.common.data.edge.Edge;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.DashboardId;
 import org.thingsboard.server.common.data.id.TenantId;
 import org.thingsboard.server.common.data.msg.TbMsgType;
@@ -130,4 +131,9 @@ public class DashboardEdgeProcessor extends BaseDashboardProcessor implements Da
         return assignedCustomers;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.DASHBOARD;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/device/DeviceEdgeProcessor.java

@@ -274,4 +274,9 @@ public class DeviceEdgeProcessor extends BaseDeviceProcessor implements DevicePr
         device.setCustomerId(customerUUID);
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.DEVICE;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/device/profile/DeviceProfileEdgeProcessor.java

@@ -136,4 +136,9 @@ public class DeviceProfileEdgeProcessor extends BaseDeviceProfileProcessor imple
         deviceProfile.setDefaultDashboardId(defaultDashboardUUID != null ? new DashboardId(defaultDashboardUUID) : null);
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.DEVICE_PROFILE;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/edge/EdgeEntityProcessor.java

@@ -113,4 +113,9 @@ public class EdgeEntityProcessor extends BaseEdgeProcessor {
         return null;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.EDGE;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/entityview/EntityViewEdgeProcessor.java

@@ -137,4 +137,9 @@ public class EntityViewEdgeProcessor extends BaseEntityViewProcessor implements
         entityView.setCustomerId(customerUUID);
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.ENTITY_VIEW;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/notification/NotificationRuleEdgeProcessor.java

@@ -20,6 +20,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.NotificationRuleId;
 import org.thingsboard.server.common.data.notification.rule.NotificationRule;
 import org.thingsboard.server.dao.notification.NotificationRuleService;
@@ -65,4 +66,9 @@ public class NotificationRuleEdgeProcessor extends BaseEdgeProcessor {
         return downlinkMsg;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.NOTIFICATION_RULE;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/notification/NotificationTargetEdgeProcessor.java

@@ -20,6 +20,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.NotificationTargetId;
 import org.thingsboard.server.common.data.notification.targets.NotificationTarget;
 import org.thingsboard.server.dao.notification.NotificationTargetService;
@@ -65,4 +66,9 @@ public class NotificationTargetEdgeProcessor extends BaseEdgeProcessor {
         return downlinkMsg;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.NOTIFICATION_TARGET;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/notification/NotificationTemplateEdgeProcessor.java

@@ -20,6 +20,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.NotificationTemplateId;
 import org.thingsboard.server.common.data.notification.template.NotificationTemplate;
 import org.thingsboard.server.dao.notification.NotificationTemplateService;
@@ -65,4 +66,9 @@ public class NotificationTemplateEdgeProcessor extends BaseEdgeProcessor {
         return downlinkMsg;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.NOTIFICATION_TEMPLATE;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/oauth2/DomainEdgeProcessor.java

@@ -21,6 +21,7 @@ import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.domain.DomainInfo;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.DomainId;
 import org.thingsboard.server.common.data.oauth2.OAuth2Client;
 import org.thingsboard.server.dao.domain.DomainService;
@@ -71,4 +72,9 @@ public class DomainEdgeProcessor extends BaseEdgeProcessor {
         return null;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.DOMAIN;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/oauth2/OAuth2ClientEdgeProcessor.java

@@ -19,6 +19,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.OAuth2ClientId;
 import org.thingsboard.server.common.data.oauth2.OAuth2Client;
 import org.thingsboard.server.gen.edge.v1.DownlinkMsg;
@@ -64,4 +65,9 @@ public class OAuth2ClientEdgeProcessor extends BaseEdgeProcessor {
         return null;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.OAUTH2_CLIENT;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/ota/OtaPackageEdgeProcessor.java

@@ -20,6 +20,7 @@ import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.OtaPackage;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.OtaPackageId;
 import org.thingsboard.server.gen.edge.v1.DownlinkMsg;
 import org.thingsboard.server.gen.edge.v1.OtaPackageUpdateMsg;
@@ -59,4 +60,9 @@ public class OtaPackageEdgeProcessor extends BaseEdgeProcessor {
         return null;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.OTA_PACKAGE;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/queue/QueueEdgeProcessor.java

@@ -19,6 +19,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.QueueId;
 import org.thingsboard.server.common.data.queue.Queue;
 import org.thingsboard.server.gen.edge.v1.DownlinkMsg;
@@ -59,4 +60,9 @@ public class QueueEdgeProcessor extends BaseEdgeProcessor {
         return null;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.QUEUE;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/relation/RelationEdgeProcessor.java

@@ -95,4 +95,9 @@ public class RelationEdgeProcessor extends BaseRelationProcessor implements Rela
                 .build();
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.RELATION;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/resource/ResourceEdgeProcessor.java

@@ -98,4 +98,9 @@ public class ResourceEdgeProcessor extends BaseResourceProcessor implements Reso
         return null;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.TB_RESOURCE;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/rule/RuleChainEdgeProcessor.java

@@ -20,6 +20,7 @@ import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.edge.Edge;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.RuleChainId;
 import org.thingsboard.server.common.data.rule.RuleChain;
 import org.thingsboard.server.common.data.rule.RuleChainMetaData;
@@ -79,4 +80,9 @@ public class RuleChainEdgeProcessor extends BaseEdgeProcessor {
         return downlinkMsg;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.RULE_CHAIN;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/rule/RuleChainMetadataEdgeProcessor.java

@@ -19,6 +19,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.RuleChainId;
 import org.thingsboard.server.common.data.rule.RuleChain;
 import org.thingsboard.server.common.data.rule.RuleChainMetaData;
@@ -51,4 +52,9 @@ public class RuleChainMetadataEdgeProcessor extends BaseEdgeProcessor {
         return null;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.RULE_CHAIN_METADATA;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/settings/AdminSettingsEdgeProcessor.java

@@ -21,6 +21,7 @@ import org.thingsboard.common.util.JacksonUtil;
 import org.thingsboard.server.common.data.AdminSettings;
 import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.gen.edge.v1.AdminSettingsUpdateMsg;
 import org.thingsboard.server.gen.edge.v1.DownlinkMsg;
 import org.thingsboard.server.queue.util.TbCoreComponent;
@@ -44,4 +45,9 @@ public class AdminSettingsEdgeProcessor extends BaseEdgeProcessor {
                 .build();
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.ADMIN_SETTINGS;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/tenant/TenantEdgeProcessor.java

@@ -22,6 +22,7 @@ import org.thingsboard.server.common.data.Tenant;
 import org.thingsboard.server.common.data.TenantProfile;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
 import org.thingsboard.server.common.data.edge.EdgeEventActionType;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.TenantId;
 import org.thingsboard.server.gen.edge.v1.DownlinkMsg;
 import org.thingsboard.server.gen.edge.v1.TenantProfileUpdateMsg;
@@ -56,4 +57,9 @@ public class TenantEdgeProcessor extends BaseEdgeProcessor {
         return null;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.TENANT;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/tenant/TenantProfileEdgeProcessor.java

@@ -21,6 +21,7 @@ import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.TenantProfile;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
 import org.thingsboard.server.common.data.edge.EdgeEventActionType;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.TenantProfileId;
 import org.thingsboard.server.gen.edge.v1.DownlinkMsg;
 import org.thingsboard.server.gen.edge.v1.TenantProfileUpdateMsg;
@@ -51,4 +52,9 @@ public class TenantProfileEdgeProcessor extends BaseEdgeProcessor {
         return null;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.TENANT_PROFILE;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/user/UserEdgeProcessor.java

@@ -20,6 +20,7 @@ import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.User;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.UserId;
 import org.thingsboard.server.common.data.security.UserCredentials;
 import org.thingsboard.server.gen.edge.v1.DownlinkMsg;
@@ -72,4 +73,9 @@ public class UserEdgeProcessor extends BaseEdgeProcessor {
         return null;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.USER;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/widget/WidgetBundleEdgeProcessor.java

@@ -19,6 +19,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.WidgetsBundleId;
 import org.thingsboard.server.common.data.widget.WidgetsBundle;
 import org.thingsboard.server.gen.edge.v1.DownlinkMsg;
@@ -62,4 +63,9 @@ public class WidgetBundleEdgeProcessor extends BaseEdgeProcessor {
         return null;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.WIDGETS_BUNDLE;
+    }
+
 }

application/src/main/java/org/thingsboard/server/service/edge/rpc/processor/widget/WidgetTypeEdgeProcessor.java

@@ -19,6 +19,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.data.EdgeUtils;
 import org.thingsboard.server.common.data.edge.EdgeEvent;
+import org.thingsboard.server.common.data.edge.EdgeEventType;
 import org.thingsboard.server.common.data.id.WidgetTypeId;
 import org.thingsboard.server.common.data.widget.WidgetTypeDetails;
 import org.thingsboard.server.gen.edge.v1.DownlinkMsg;
@@ -59,4 +60,9 @@ public class WidgetTypeEdgeProcessor extends BaseEdgeProcessor {
         return null;
     }
 
+    @Override
+    public EdgeEventType getEdgeEventType() {
+        return EdgeEventType.WIDGET_TYPE;
+    }
+
 }