yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-02 19:48:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix Event Handlers registration Issue (#16544)

Browse Source 
* Fix Event Handlers Issue

* Review Comments
This commit is contained in:
Mohit Yadav 2024-06-05 22:40:02 +05:30 committed by GitHub
parent dff0aa8dbe
commit d374e48b79
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 17 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
openmetadata-service/src/main/java/org/openmetadata/service/events/EventFilter.java
View File

@ -13,6 +13,8 @@
package org.openmetadata.service.events; package org.openmetadata.service.events;
import static org.openmetadata.common.utils.CommonUtil.nullOrEmpty;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.HashSet; import java.util.HashSet;
@ -44,22 +46,26 @@ public class EventFilter implements ContainerResponseFilter {
registerEventHandlers(config); registerEventHandlers(config);
} }
@SuppressWarnings("unchecked")
private void registerEventHandlers(OpenMetadataApplicationConfig config) { private void registerEventHandlers(OpenMetadataApplicationConfig config) {
try { if (nullOrEmpty(config.getEventHandlerConfiguration())) {
Set<String> eventHandlerClassNames = Set<String> eventHandlerClassNames =
new HashSet<>(config.getEventHandlerConfiguration().getEventHandlerClassNames()); new HashSet<>(config.getEventHandlerConfiguration().getEventHandlerClassNames());
for (String eventHandlerClassName : eventHandlerClassNames) { for (String eventHandlerClassName : eventHandlerClassNames) {
@SuppressWarnings("unchecked") try {
EventHandler eventHandler = EventHandler eventHandler =
((Class<EventHandler>) Class.forName(eventHandlerClassName)) ((Class<EventHandler>) Class.forName(eventHandlerClassName))
.getConstructor() .getConstructor()
.newInstance(); .newInstance();
eventHandler.init(config); eventHandler.init(config);
eventHandlers.add(eventHandler); eventHandlers.add(eventHandler);
LOG.info("Added event handler {}", eventHandlerClassName); LOG.info("Added event handler {}", eventHandlerClassName);
} catch (Exception e) {
LOG.info("Exception ", e);
}
} }
} catch (Exception e) { } else {
LOG.info("Exception ", e); LOG.info("Event handler configuration is empty");
} }
} }