Revert disabling notifications

nikhilbonte21 · nikhilbonte21 · commit bdb6ec221979 · 2024-11-27T13:55:44.000+05:30
diff --git a/webapp/src/main/java/org/apache/atlas/notification/EntityNotificationListenerV2.java b/webapp/src/main/java/org/apache/atlas/notification/EntityNotificationListenerV2.java
@@ -236,7 +236,7 @@ private void sendNotifications(OperationType operationType, List<EntityNotificat
     }
 
     private void sendNotifications(OperationType operationType, List<EntityNotificationV2> messages, boolean forceInline) throws AtlasBaseException {
-        /*if (!messages.isEmpty()) {
+        if (!messages.isEmpty()) {
             try {
                 if (forceInline) {
                     inlineNotificationSender.send(operationType, messages);
@@ -247,7 +247,7 @@ private void sendNotifications(OperationType operationType, List<EntityNotificat
             } catch (NotificationException e) {
                 throw new AtlasBaseException(AtlasErrorCode.ENTITY_NOTIFICATION_FAILED, e, operationType.name());
             }
-        }*/
+        }
     }
 
     private AtlasEntityHeaderWithRelations toNotificationHeader(AtlasEntity entity) {

Original file line number	Diff line number	Diff line change
`@@ -236,7 +236,7 @@ private void sendNotifications(OperationType operationType, List<EntityNotificat`
`236`	`236`	`}`
`237`	`237`
`238`	`238`	`private void sendNotifications(OperationType operationType, List<EntityNotificationV2> messages, boolean forceInline) throws AtlasBaseException {`
`239`		`- /*if (!messages.isEmpty()) {`
	`239`	`+ if (!messages.isEmpty()) {`
`240`	`240`	`try {`
`241`	`241`	`if (forceInline) {`
`242`	`242`	`inlineNotificationSender.send(operationType, messages);`
`@@ -247,7 +247,7 @@ private void sendNotifications(OperationType operationType, List<EntityNotificat`
`247`	`247`	`} catch (NotificationException e) {`
`248`	`248`	`throw new AtlasBaseException(AtlasErrorCode.ENTITY_NOTIFICATION_FAILED, e, operationType.name());`
`249`	`249`	`}`
`250`		`- }*/`
	`250`	`+ }`
`251`	`251`	`}`
`252`	`252`
`253`	`253`	`private AtlasEntityHeaderWithRelations toNotificationHeader(AtlasEntity entity) {`