ATLAS-2844: added eventTime field in EntityNotificationV2

intg/src/main/java/org/apache/atlas/model/notification/EntityNotification.java

@@ -105,16 +105,22 @@ public class EntityNotification implements Serializable {
 
         private AtlasEntityHeader entity;
         private OperationType     operationType;
+        private long              eventTime;
 
         public EntityNotificationV2() {
-            super(ENTITY_NOTIFICATION_V2);
+            this(null, null, System.currentTimeMillis());
         }
 
         public EntityNotificationV2(AtlasEntityHeader entity, OperationType operationType) {
+            this(entity, operationType, System.currentTimeMillis());
+        }
+
+        public EntityNotificationV2(AtlasEntityHeader entity, OperationType operationType, long eventTime) {
             super(ENTITY_NOTIFICATION_V2);
 
             setEntity(entity);
             setOperationType(operationType);
+            setEventTime(eventTime);
         }
 
         public AtlasEntityHeader getEntity() {
@@ -133,6 +139,14 @@ public class EntityNotification implements Serializable {
             this.operationType = operationType;
         }
 
+        public long getEventTime() {
+            return eventTime;
+        }
+
+        public void setEventTime(long eventTime) {
+            this.eventTime = eventTime;
+        }
+
         @Override
         public boolean equals(Object o) {
             if (this == o) { return true; }
@@ -163,6 +177,7 @@ public class EntityNotification implements Serializable {
                 sb.append(entity);
             }
             sb.append(", operationType=").append(operationType);
+            sb.append(", eventTime=").append(eventTime);
             sb.append("}");
 
             return sb;

webapp/src/main/java/org/apache/atlas/notification/EntityNotificationListenerV2.java

@@ -125,7 +125,7 @@ public class EntityNotificationListenerV2 implements EntityChangeListenerV2 {
                 continue;
             }
 
-            messages.add(new EntityNotificationV2(toNotificationHeader(entity), operationType));
+            messages.add(new EntityNotificationV2(toNotificationHeader(entity), operationType, RequestContext.get().getRequestTime()));
         }
 
         if (!messages.isEmpty()) {