1 files changed, 20 insertions, 0 deletions
diff --git a/src/main/java/org/onap/dcae/common/model/VesEvent.java b/src/main/java/org/onap/dcae/common/model/VesEvent.java
index ce709d1c..6c9a8ee2 100644
--- a/src/main/java/org/onap/dcae/common/model/VesEvent.java
+++ b/src/main/java/org/onap/dcae/common/model/VesEvent.java
@@ -19,6 +19,9 @@
  */
 package org.onap.dcae.common.model;
 
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import org.json.JSONObject;
 
 /**
@@ -35,6 +38,8 @@ public class VesEvent {
     private static final String DOMAIN = "domain";
     private static final String STND_DEFINED_NAMESPACE = "stndDefinedNamespace";
     private static final String STND_DEFINED_DOMAIN = "stndDefined";
+    private static final String STND_DEFINED_FIELDS = "stndDefinedFields";
+    private static final String SCHEMA_REFERENCE = "schemaReference";
 
     private final JSONObject event;
 
@@ -66,6 +71,16 @@ public class VesEvent {
         return getEventHeader().getString(DOMAIN);
     }
 
+    public String getSchemaReference() {
+        return getStndDefinedFields().getString(SCHEMA_REFERENCE);
+    }
+
+    private JSONObject getStndDefinedFields() {
+        return event
+                .getJSONObject(EVENT_LITERAL)
+                .getJSONObject(STND_DEFINED_FIELDS);
+    }
+
     private String resolveDomainForStndDefinedEvent() {
         final JSONObject eventHeader = getEventHeader();
         if(eventHeader.has(STND_DEFINED_NAMESPACE)) {
@@ -108,6 +123,11 @@ public class VesEvent {
         return new JSONObject(event.toString());
     }
 
+    public JsonNode asJsonNode() throws JsonProcessingException {
+        ObjectMapper objectMapper = new ObjectMapper();
+        return objectMapper.readTree(event.toString());
+    }
+
     /**
      * Checks if type of event is same as given in paramaters.
      *