(atlas) branch atlas-5320 updated: ATLAS-5320: Distributed Notification Processing - fixing failed tests NotificationHookConsumerTest

[radhikakundam]

This is an automated email from the ASF dual-hosted git repository.

asf-gitbox-commits pushed a commit to branch atlas-5320
in repository https://gitbox.apache.org/repos/asf/atlas.git


The following commit(s) were added to refs/heads/atlas-5320 by this push:
     new b79f30448 ATLAS-5320: Distributed Notification Processing - fixing 
failed tests NotificationHookConsumerTest
b79f30448 is described below

commit b79f3044814079b5c784b8600d9a2d7a869b4021
Author: Radhika Kundam <radhika.kun...@gmail.com>
AuthorDate: Thu Jun 18 10:23:38 2026 -0700

    ATLAS-5320: Distributed Notification Processing - fixing failed tests 
NotificationHookConsumerTest
---
 .../org/apache/atlas/notification/NotificationHookConsumerTest.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerTest.java
 
b/webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerTest.java
index 752985053..2d9bb24a0 100644
--- 
a/webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerTest.java
+++ 
b/webapp/src/test/java/org/apache/atlas/notification/NotificationHookConsumerTest.java
@@ -1844,7 +1844,7 @@ public class NotificationHookConsumerTest {
         Object hookConsumer = createHookConsumer(consumer, 
notificationConsumer);
 
         Object entityProcessor = getEntityProcessor(hookConsumer);
-        Method recordFailedMethod = 
SerialEntityProcessor.class.getDeclaredMethod("recordFailedMessages", 
List.class);
+        Method recordFailedMethod = 
SerialEntityProcessor.class.getDeclaredMethod("recordFailedMessages", 
String.class, List.class);
         recordFailedMethod.setAccessible(true);
 
         // Add some failed messages
@@ -1855,7 +1855,7 @@ public class NotificationHookConsumerTest {
         failedMessages.add("failed message 1");
         failedMessages.add("failed message 2");
 
-        recordFailedMethod.invoke(entityProcessor, failedMessages);
+        recordFailedMethod.invoke(entityProcessor, "test-topic", 
failedMessages);
 
         assertTrue(failedMessages.isEmpty()); // Should be cleared after 
recording
     }