ATLAS-2844: added eventTime field in EntityNotificationV2
diff --git a/intg/src/main/java/org/apache/atlas/model/notification/EntityNotification.java b/intg/src/main/java/org/apache/atlas/model/notification/EntityNotification.java
index 6cdae89..1eae100 100644
--- a/intg/src/main/java/org/apache/atlas/model/notification/EntityNotification.java
+++ b/intg/src/main/java/org/apache/atlas/model/notification/EntityNotification.java
@@ -105,16 +105,22 @@
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 @@
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 @@
sb.append(entity);
}
sb.append(", operationType=").append(operationType);
+ sb.append(", eventTime=").append(eventTime);
sb.append("}");
return sb;
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 9587af9..e0a60a1 100644
--- a/webapp/src/main/java/org/apache/atlas/notification/EntityNotificationListenerV2.java
+++ b/webapp/src/main/java/org/apache/atlas/notification/EntityNotificationListenerV2.java
@@ -125,7 +125,7 @@
continue;
}
- messages.add(new EntityNotificationV2(toNotificationHeader(entity), operationType));
+ messages.add(new EntityNotificationV2(toNotificationHeader(entity), operationType, RequestContext.get().getRequestTime()));
}
if (!messages.isEmpty()) {
