From 9f3282ce9c44449e9dac5ee52aa5e18e8c32bfb6 Mon Sep 17 00:00:00 2001 From: arpit-at <arpit.upadhyay@atlan.com> Date: Fri, 12 Jul 2024 18:32:34 +0530 Subject: [PATCH] DG-1697: Adding endpoint for linking/unlink policy --- .../atlas/notification/EntityNotificationListenerV2.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/webapp/src/main/java/org/apache/atlas/notification/EntityNotificationListenerV2.java b/webapp/src/main/java/org/apache/atlas/notification/EntityNotificationListenerV2.java index 06b8f9678d5..23ec7ea1412 100644 --- a/webapp/src/main/java/org/apache/atlas/notification/EntityNotificationListenerV2.java +++ b/webapp/src/main/java/org/apache/atlas/notification/EntityNotificationListenerV2.java @@ -174,7 +174,7 @@ private void notifyEntityEvents(List<AtlasEntity> entities, OperationType operat } } - + LOG.info("Arpit has reached till send notification size: {} content: {} ", messages.size(), messages.get(0).toString()); sendNotifications(operationType, messages); RequestContext.get().endMetricRecord(metric); } @@ -245,6 +245,7 @@ private void sendNotifications(OperationType operationType, List<EntityNotificat notificationSender.send(operationType, messages); } } catch (NotificationException e) { + LOG.error("Arpit has reached till check - error:", e); throw new AtlasBaseException(AtlasErrorCode.ENTITY_NOTIFICATION_FAILED, e, operationType.name()); } }