Commit 6a18b5c6 by Madhan Neethiraj

ATLAS-2192: notification consumer updates to handle stale split messages (#2)

parent 9a8c7125
......@@ -85,7 +85,16 @@ public abstract class AtlasHook {
notificationRetryInterval = atlasProperties.getInt(ATLAS_NOTIFICATION_RETRY_INTERVAL, 1000);
notificationInterface = NotificationProvider.get();
notificationInterface.setCurrentUser(getUser());
String currentUser = "";
try {
currentUser = getUser();
} catch (Exception excp) {
LOG.warn("Error in determining current user", excp);
}
notificationInterface.setCurrentUser(currentUser);
LOG.info("Created Atlas Hook");
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment