X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=dcae-analytics-cdap-common%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fdcae%2Fapod%2Fanalytics%2Fcdap%2Fcommon%2Fpersistance%2Ftca%2FTCAMessageStatusPersister.java;fp=dcae-analytics-cdap-common%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fdcae%2Fapod%2Fanalytics%2Fcdap%2Fcommon%2Fpersistance%2Ftca%2FTCAMessageStatusPersister.java;h=0b34371fca936d466e12e6373dfcdd610426d6a0;hb=49056420f9d23880502852b234e361fb4ea2bfeb;hp=89d8d00fd600276cf5c7fbe762d5b02dc845b0ea;hpb=274a2398e0fd209c5589979beb3c4d339e592d80;p=dcaegen2%2Fanalytics%2Ftca.git diff --git a/dcae-analytics-cdap-common/src/main/java/org/onap/dcae/apod/analytics/cdap/common/persistance/tca/TCAMessageStatusPersister.java b/dcae-analytics-cdap-common/src/main/java/org/onap/dcae/apod/analytics/cdap/common/persistance/tca/TCAMessageStatusPersister.java index 89d8d00..0b34371 100644 --- a/dcae-analytics-cdap-common/src/main/java/org/onap/dcae/apod/analytics/cdap/common/persistance/tca/TCAMessageStatusPersister.java +++ b/dcae-analytics-cdap-common/src/main/java/org/onap/dcae/apod/analytics/cdap/common/persistance/tca/TCAMessageStatusPersister.java @@ -3,6 +3,7 @@ * dcae-analytics * ================================================================================ * Copyright © 2017 AT&T Intellectual Property. All rights reserved. + * Modifications Copyright (C) 2019 Samsung. All rights reserved. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -106,8 +107,9 @@ public abstract class TCAMessageStatusPersister { final String domain = domainAndEventName.getLeft(); final String eventName = domainAndEventName.getRight(); - final TCAMessageStatusEntity tcaMessageStatusEntity = new TCAMessageStatusEntity(currentTS, - instanceId, calculatorMessageType.name(), vesMessage, domain, eventName); + final TCAMessageStatusEntity tcaMessageStatusEntity = new TCAMessageStatusEntity.TCAMessageStatusEntityBuilder() + .setCreationTS(currentTS).setInstanceId(instanceId).setMessageType(calculatorMessageType.name()) + .setVesMessage(vesMessage).setDomain(domain).setEventName(eventName).createTCAMessageStatusEntity(); // add threshold violation fields addViolatedThreshold(tcaMessageStatusEntity, processorContext);