Repository: atlas Updated Branches: refs/heads/master 8d86dd2c6 -> bf4bf7fea
ATLAS-2456: tag propagation - updated entity notification deserializer to handle V2 messages - #3 Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/bf4bf7fe Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/bf4bf7fe Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/bf4bf7fe Branch: refs/heads/master Commit: bf4bf7fea74e429473b3f2104f2327d5c93cf414 Parents: 8d86dd2 Author: Madhan Neethiraj <mad...@apache.org> Authored: Thu Feb 22 23:59:52 2018 -0800 Committer: Madhan Neethiraj <mad...@apache.org> Committed: Thu Feb 22 23:59:52 2018 -0800 ---------------------------------------------------------------------- intg/src/main/java/org/apache/atlas/utils/AtlasJson.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/atlas/blob/bf4bf7fe/intg/src/main/java/org/apache/atlas/utils/AtlasJson.java ---------------------------------------------------------------------- diff --git a/intg/src/main/java/org/apache/atlas/utils/AtlasJson.java b/intg/src/main/java/org/apache/atlas/utils/AtlasJson.java index 4f7b716..9aacb2d 100644 --- a/intg/src/main/java/org/apache/atlas/utils/AtlasJson.java +++ b/intg/src/main/java/org/apache/atlas/utils/AtlasJson.java @@ -39,6 +39,7 @@ import org.apache.atlas.v1.model.instance.Id; import org.apache.atlas.v1.model.instance.Referenceable; import org.apache.atlas.v1.model.instance.Struct; import org.apache.atlas.v1.model.notification.EntityNotificationV1; +import org.apache.atlas.v1.model.notification.EntityNotificationV2; import org.apache.atlas.v1.model.notification.HookNotificationV1.*; import org.apache.commons.collections.MapUtils; import org.slf4j.Logger; @@ -386,6 +387,10 @@ public class AtlasJson { case ENTITY_NOTIFICATION_V1: ret = mapper.treeToValue(root, EntityNotificationV1.class); break; + + case ENTITY_NOTIFICATION_V2: + ret = mapper.treeToValue(root, EntityNotificationV2.class); + break; } }
