public enum ResponseType {
SUCCESS, PARTIAL_SUCCESS, FAILURE;
public enum ResponseType {
SUCCESS, PARTIAL_SUCCESS, FAILURE;
LoggerFactory loggerFactoryInstance = LoggerFactory.getInstance();
logger = loggerFactoryInstance.getLogger(EntityEventPolicy.class.getName());
metricsLogger = loggerFactoryInstance.getMetricsLogger(EntityEventPolicy.class.getName());
LoggerFactory loggerFactoryInstance = LoggerFactory.getInstance();
logger = loggerFactoryInstance.getLogger(EntityEventPolicy.class.getName());
metricsLogger = loggerFactoryInstance.getMetricsLogger(EntityEventPolicy.class.getName());
this.externalOxmModelProcessors.add(EntityOxmReferenceHelper.getInstance());
OxmModelLoader.registerExternalOxmModelProcessors(externalOxmModelProcessors);
OxmModelLoader.loadModels();
this.externalOxmModelProcessors.add(EntityOxmReferenceHelper.getInstance());
OxmModelLoader.registerExternalOxmModelProcessors(externalOxmModelProcessors);
OxmModelLoader.loadModels();
*/
public static String convertObjectToJson(Object object, boolean pretty)
throws JsonProcessingException {
*/
public static String convertObjectToJson(Object object, boolean pretty)
throws JsonProcessingException {
eventHeader = initializeUebEventHeader(uebObjHeader.toString());
// Get src domain from header; discard event if not originated from same domain
eventHeader = initializeUebEventHeader(uebObjHeader.toString());
// Get src domain from header; discard event if not originated from same domain
RouterServiceUtil.extractFieldValuesFromObject(n, cerDescriptor.getAttributeNames(),
extractedParentEntityAttributeValues);
RouterServiceUtil.extractFieldValuesFromObject(n, cerDescriptor.getAttributeNames(),
extractedParentEntityAttributeValues);
RouterServiceUtil.extractObjectsByKey(n, cerDescriptor.getTargetEntityType(),
nestedTargetEntityInstances);
RouterServiceUtil.extractObjectsByKey(n, cerDescriptor.getTargetEntityType(),
nestedTargetEntityInstances);
if (targetEntityInstance.has("link")) { // nested SI has url mentioned
targetEntityUrl = RouterServiceUtil.getNodeFieldAsText(targetEntityInstance,
"link");
if (targetEntityInstance.has("link")) { // nested SI has url mentioned
targetEntityUrl = RouterServiceUtil.getNodeFieldAsText(targetEntityInstance,
"link");
targetEntityInstance.has("service-instance-id")){
targetEntityUrl += "/" + RouterServiceUtil.getNodeFieldAsText(targetEntityInstance,
"service-instance-id");
targetEntityInstance.has("service-instance-id")){
targetEntityUrl += "/" + RouterServiceUtil.getNodeFieldAsText(targetEntityInstance,
"service-instance-id");
Map<String, OxmEntityDescriptor> rootDescriptor =
oxmEntities.getSuggestableEntityDescriptors();
if (!rootDescriptor.isEmpty()) {
Map<String, OxmEntityDescriptor> rootDescriptor =
oxmEntities.getSuggestableEntityDescriptors();
if (!rootDescriptor.isEmpty()) {
List<String> suggestibleAttrInOxm = extractSuggestableAttr(oxmEntities, entityType);
if (suggestibleAttrInOxm != null) {
for (String attr: suggestibleAttrInOxm){
List<String> suggestibleAttrInOxm = extractSuggestableAttr(oxmEntities, entityType);
if (suggestibleAttrInOxm != null) {
for (String attr: suggestibleAttrInOxm){
Map<String, OxmEntityDescriptor> rootDescriptor = oxmEntities.getSuggestableEntityDescriptors();
if (rootDescriptor == null) {
Map<String, OxmEntityDescriptor> rootDescriptor = oxmEntities.getSuggestableEntityDescriptors();
if (rootDescriptor == null) {
Map<String, OxmEntityDescriptor> rootDescriptor = oxmEntities.getEntityAliasDescriptors();
if (rootDescriptor == null) {
Map<String, OxmEntityDescriptor> rootDescriptor = oxmEntities.getEntityAliasDescriptors();
if (rootDescriptor == null) {
jsonNode = mapper.readTree(mapper.getJsonFactory().createJsonParser(payload));
} catch (IOException e) {
logger.debug(EntityEventPolicyMsgs.FAILED_TO_PARSE_UEB_PAYLOAD, ENTITY_HEADER + " missing",
jsonNode = mapper.readTree(mapper.getJsonFactory().createJsonParser(payload));
} catch (IOException e) {
logger.debug(EntityEventPolicyMsgs.FAILED_TO_PARSE_UEB_PAYLOAD, ENTITY_HEADER + " missing",
if (searchTagField.equalsIgnoreCase(aaiEventEntity.getEntityPrimaryKeyName())) {
searchTagValue = aaiEventEntity.getEntityPrimaryKeyValue();
} else {
if (searchTagField.equalsIgnoreCase(aaiEventEntity.getEntityPrimaryKeyName())) {
searchTagValue = aaiEventEntity.getEntityPrimaryKeyValue();
} else {
- List<String> primaryKeyValues = new ArrayList<String>();
- List<String> primaryKeyNames = new ArrayList<String>();
- String pkeyValue = null;
+ List<String> primaryKeyValues = new ArrayList<>();
+ List<String> primaryKeyNames = new ArrayList<>();
+ String pkeyValue;
for (String keyName : resultDescriptor.getPrimaryKeyAttributeName()) {
pkeyValue = RouterServiceUtil.getNodeFieldAsText(entityNode, keyName);
for (String keyName : resultDescriptor.getPrimaryKeyAttributeName()) {
pkeyValue = RouterServiceUtil.getNodeFieldAsText(entityNode, keyName);
headers.put(Headers.TRANSACTION_ID, Arrays.asList(MDC.get(MdcContext.MDC_REQUEST_ID)));
String entityId = aaiEventEntity.getId();
headers.put(Headers.TRANSACTION_ID, Arrays.asList(MDC.get(MdcContext.MDC_REQUEST_ID)));
String entityId = aaiEventEntity.getId();
// Run the GET to retrieve the ETAG from the search service
OperationResult storedEntity = searchAgent.getDocument(entitySearchIndex, entityId);
// Run the GET to retrieve the ETAG from the search service
OperationResult storedEntity = searchAgent.getDocument(entitySearchIndex, entityId);
headers.put(Headers.IF_MATCH, etag);
} else {
logger.error(EntityEventPolicyMsgs.NO_ETAG_AVAILABLE_FAILURE,
entitySearchIndex, entityId);
}
headers.put(Headers.IF_MATCH, etag);
} else {
logger.error(EntityEventPolicyMsgs.NO_ETAG_AVAILABLE_FAILURE,
entitySearchIndex, entityId);
}
NodeUtils.extractObjectsByKey(
NodeUtils.convertJsonStrToJsonNode(storedEntity.getResult()),
"content", sourceObject);
NodeUtils.extractObjectsByKey(
NodeUtils.convertJsonStrToJsonNode(storedEntity.getResult()),
"content", sourceObject);
if (HttpUtil.isHttpResponseClassSuccess(storedEntity.getResultCode())) {
List<String> etag = storedEntity.getHeaders().get(Headers.ETAG);
if (HttpUtil.isHttpResponseClassSuccess(storedEntity.getResultCode())) {
List<String> etag = storedEntity.getHeaders().get(Headers.ETAG);
headers.put(Headers.IF_MATCH, etag);
} else {
logger.error(EntityEventPolicyMsgs.NO_ETAG_AVAILABLE_FAILURE, index,
headers.put(Headers.IF_MATCH, etag);
} else {
logger.error(EntityEventPolicyMsgs.NO_ETAG_AVAILABLE_FAILURE, index,
if (HttpUtil.isHttpResponseClassSuccess(storedEntity.getResultCode())) {
List<String> etag = storedEntity.getHeaders().get(Headers.ETAG);
if (HttpUtil.isHttpResponseClassSuccess(storedEntity.getResultCode())) {
List<String> etag = storedEntity.getHeaders().get(Headers.ETAG);
headers.put(Headers.IF_MATCH, etag);
} else {
logger.error(EntityEventPolicyMsgs.NO_ETAG_AVAILABLE_FAILURE, index,
headers.put(Headers.IF_MATCH, etag);
} else {
logger.error(EntityEventPolicyMsgs.NO_ETAG_AVAILABLE_FAILURE, index,
String entityPrimaryKeyFieldValue) {
Map<String, String> topoData = new HashMap<>();
String entityPrimaryKeyFieldValue) {
Map<String, String> topoData = new HashMap<>();
List<String> topographicalAttr =
getOxmAttributes(payload, oxmJaxbContext, oxmEntityType, entityType, "geoProps");
if (topographicalAttr == null) {
List<String> topographicalAttr =
getOxmAttributes(payload, oxmJaxbContext, oxmEntityType, entityType, "geoProps");
if (topographicalAttr == null) {
"Topograhical attribute not found for payload entity type '" + entityType + "'");
logger.debug(EntityEventPolicyMsgs.DISCARD_UPDATING_TOPOGRAPHY_DATA_VERBOSE,
"Topograhical attribute not found for payload entity type '" + entityType + "'",
"Topograhical attribute not found for payload entity type '" + entityType + "'");
logger.debug(EntityEventPolicyMsgs.DISCARD_UPDATING_TOPOGRAPHY_DATA_VERBOSE,
"Topograhical attribute not found for payload entity type '" + entityType + "'",
} else {
entityLink = lookupValueUsingKey(payload, "entity-link");
for (String topoAttr : topographicalAttr) {
} else {
entityLink = lookupValueUsingKey(payload, "entity-link");
for (String topoAttr : topographicalAttr) {