diff options
author | 2018-06-18 17:30:21 +0100 | |
---|---|---|
committer | 2018-06-18 17:36:33 +0100 | |
commit | f518411876d6830d83d051a915f0b21bdfdcb43e (patch) | |
tree | 189fb1e3a7650159b0237f29d54a997b4ffbbf78 /src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicy.java | |
parent | 72da66902a3efaff3068ed2b3f4f7eb3bb5fe43f (diff) |
Add multi-oxm using schemaIngest library
Use the schemaIngest library to have the
capability to deal with multiple OXM files
Issue-ID: AAI-1192
Change-Id: Icbebbf475bcf9fc3808bc79b9fa95085db46ab77
Signed-off-by: gabriel sanchez <gabriel.sanchez@amdocs.com>
Diffstat (limited to 'src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicy.java')
-rw-r--r-- | src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicy.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicy.java b/src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicy.java index caee8b4..8f0e426 100644 --- a/src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicy.java +++ b/src/main/java/org/onap/aai/datarouter/policy/SpikeEntityEventPolicy.java @@ -50,7 +50,7 @@ import org.onap.aai.datarouter.entity.SpikeEventVertex; import org.onap.aai.datarouter.logging.EntityEventPolicyMsgs; import org.onap.aai.datarouter.util.EntityOxmReferenceHelper; import org.onap.aai.datarouter.util.ExternalOxmModelProcessor; -import org.onap.aai.datarouter.util.OxmModelLoader; +import org.onap.aai.datarouter.schema.OxmModelLoader; import org.onap.aai.datarouter.util.RouterServiceUtil; import org.onap.aai.datarouter.util.SearchServiceAgent; import org.onap.aai.restclient.client.Headers; @@ -291,7 +291,7 @@ public class SpikeEntityEventPolicy implements Processor { return; } - DynamicJAXBContext oxmJaxbContext = loadOxmContext(oxmVersion.toLowerCase()); + DynamicJAXBContext oxmJaxbContext = loadOxmContext(oxmVersion); if (oxmJaxbContext == null) { logger.error(EntityEventPolicyMsgs.OXM_VERSION_NOT_SUPPORTED, oxmVersion); logger.debug(EntityEventPolicyMsgs.DISCARD_EVENT_VERBOSE, "OXM version mismatch", eventPayload); @@ -526,7 +526,7 @@ public class SpikeEntityEventPolicy implements Processor { private List<String> getOxmAttributes(DynamicJAXBContext oxmJaxbContext, String oxmEntityType, String entityType, String fieldName) { - DynamicType entity = (DynamicType) oxmJaxbContext.getDynamicType(oxmEntityType); + DynamicType entity = oxmJaxbContext.getDynamicType(oxmEntityType); if (entity == null) { return null; } |