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%2FTCAMessageStatusEntity.java;fp=dcae-analytics-cdap-common%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fdcae%2Fapod%2Fanalytics%2Fcdap%2Fcommon%2Fpersistance%2Ftca%2FTCAMessageStatusEntity.java;h=64b116e9722b9d7d0a38d9bd205108aa3b213df1;hb=49056420f9d23880502852b234e361fb4ea2bfeb;hp=b3edc64662f1bca3021fbbe6a9b48bd44ac0191f;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/TCAMessageStatusEntity.java b/dcae-analytics-cdap-common/src/main/java/org/onap/dcae/apod/analytics/cdap/common/persistance/tca/TCAMessageStatusEntity.java index b3edc64..64b116e 100644 --- a/dcae-analytics-cdap-common/src/main/java/org/onap/dcae/apod/analytics/cdap/common/persistance/tca/TCAMessageStatusEntity.java +++ b/dcae-analytics-cdap-common/src/main/java/org/onap/dcae/apod/analytics/cdap/common/persistance/tca/TCAMessageStatusEntity.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. @@ -82,62 +83,161 @@ public class TCAMessageStatusEntity implements Writable, Serializable { */ public TCAMessageStatusEntity(final long creationTS, final int instanceId, final String messageType, final String vesMessage, final String domain, final String eventName) { - this(creationTS, instanceId, messageType, vesMessage, domain, eventName, null, null, null, null, - null, null, null, null, null, null, null, null, null); + + this(new TCAMessageStatusEntity.TCAMessageStatusEntityBuilder().setCreationTS(creationTS) + .setInstanceId(instanceId).setMessageType(messageType).setVesMessage(vesMessage).setDomain(domain) + .setEventName(eventName)); } /** * Create new Instance of {@link TCAMessageStatusEntity} * - * @param creationTS creation Timestamp - * @param instanceId CDAP flowlet instance ID - * @param messageType {@link TCACalculatorMessageType} - * @param vesMessage incoming VES message from collector - * @param domain VES message domain if present - * @param eventName VES message event name if present - * @param thresholdPath Violated threshold path - * @param thresholdSeverity Violated threshold Severity if any - * @param thresholdDirection Violated threshold Direction if any - * @param thresholdValue Violated threshold value if any - * @param jsonProcessorStatus {@link TCACEFJsonProcessor} status - * @param jsonProcessorMessage {@link TCACEFJsonProcessor} message - * @param domainFilterStatus {@link TCACEFPolicyDomainFilter} status - * @param domainFilterMessage {@link TCACEFPolicyDomainFilter} message - * @param eventNameFilterStatus {@link TCACEFPolicyEventNameFilter} status - * @param eventNameFilterMessage {@link TCACEFPolicyEventNameFilter} message - * @param thresholdCalculatorStatus {@link TCACEFPolicyThresholdsProcessor} status - * @param thresholdCalculatorMessage {@link TCACEFPolicyThresholdsProcessor} message - * @param alertMessage alert message that will be sent out in case of threshold violation - */ - public TCAMessageStatusEntity(long creationTS, int instanceId, String messageType, String vesMessage, - String domain, String eventName, - String thresholdPath, String thresholdSeverity, String thresholdDirection, - Long thresholdValue, - String jsonProcessorStatus, String jsonProcessorMessage, - String domainFilterStatus, String domainFilterMessage, - String eventNameFilterStatus, String eventNameFilterMessage, - String thresholdCalculatorStatus, String thresholdCalculatorMessage, - String alertMessage) { - this.creationTS = creationTS; - this.instanceId = instanceId; - this.messageType = messageType; - this.vesMessage = vesMessage; - this.domain = domain; - this.eventName = eventName; - this.thresholdPath = thresholdPath; - this.thresholdSeverity = thresholdSeverity; - this.thresholdDirection = thresholdDirection; - this.thresholdValue = thresholdValue; - this.jsonProcessorStatus = jsonProcessorStatus; - this.jsonProcessorMessage = jsonProcessorMessage; - this.domainFilterStatus = domainFilterStatus; - this.domainFilterMessage = domainFilterMessage; - this.eventNameFilterStatus = eventNameFilterStatus; - this.eventNameFilterMessage = eventNameFilterMessage; - this.thresholdCalculatorStatus = thresholdCalculatorStatus; - this.thresholdCalculatorMessage = thresholdCalculatorMessage; - this.alertMessage = alertMessage; + * @param builder {@link TCAMessageStatusEntityBuilder} + */ + + public TCAMessageStatusEntity(TCAMessageStatusEntityBuilder builder) { + this.creationTS = builder.creationTS; + this.instanceId = builder.instanceId; + this.messageType = builder.messageType; + this.vesMessage = builder.vesMessage; + this.domain = builder.domain; + this.eventName = builder.eventName; + this.thresholdPath = builder.thresholdPath; + this.thresholdSeverity = builder.thresholdSeverity; + this.thresholdDirection = builder.thresholdDirection; + this.thresholdValue = builder.thresholdValue; + this.jsonProcessorStatus = builder.jsonProcessorStatus; + this.jsonProcessorMessage = builder.jsonProcessorMessage; + this.domainFilterStatus = builder.domainFilterStatus; + this.domainFilterMessage = builder.domainFilterMessage; + this.eventNameFilterStatus = builder.eventNameFilterStatus; + this.eventNameFilterMessage = builder.eventNameFilterMessage; + this.thresholdCalculatorStatus = builder.thresholdCalculatorStatus; + this.thresholdCalculatorMessage = builder.thresholdCalculatorMessage; + this.alertMessage = builder.alertMessage; + + } + + public static class TCAMessageStatusEntityBuilder { + private long creationTS; + private int instanceId; + private String messageType; + private String vesMessage; + private String domain; + private String eventName; + private String thresholdPath = null; + private String thresholdSeverity = null; + private String thresholdDirection = null; + private Long thresholdValue = null; + private String jsonProcessorStatus = null; + private String jsonProcessorMessage = null; + private String domainFilterStatus = null; + private String domainFilterMessage = null; + private String eventNameFilterStatus = null; + private String eventNameFilterMessage = null; + private String thresholdCalculatorStatus = null; + private String thresholdCalculatorMessage = null; + private String alertMessage = null; + + public TCAMessageStatusEntityBuilder setCreationTS(long creationTS) { + this.creationTS = creationTS; + return this; + } + + public TCAMessageStatusEntityBuilder setInstanceId(int instanceId) { + this.instanceId = instanceId; + return this; + } + + public TCAMessageStatusEntityBuilder setMessageType(String messageType) { + this.messageType = messageType; + return this; + } + + public TCAMessageStatusEntityBuilder setVesMessage(String vesMessage) { + this.vesMessage = vesMessage; + return this; + } + + public TCAMessageStatusEntityBuilder setDomain(String domain) { + this.domain = domain; + return this; + } + + public TCAMessageStatusEntityBuilder setEventName(String eventName) { + this.eventName = eventName; + return this; + } + + public TCAMessageStatusEntityBuilder setThresholdPath(String thresholdPath) { + this.thresholdPath = thresholdPath; + return this; + } + + public TCAMessageStatusEntityBuilder setThresholdSeverity(String thresholdSeverity) { + this.thresholdSeverity = thresholdSeverity; + return this; + } + + public TCAMessageStatusEntityBuilder setThresholdDirection(String thresholdDirection) { + this.thresholdDirection = thresholdDirection; + return this; + } + + public TCAMessageStatusEntityBuilder setThresholdValue(Long thresholdValue) { + this.thresholdValue = thresholdValue; + return this; + } + + public TCAMessageStatusEntityBuilder setJsonProcessorStatus(String jsonProcessorStatus) { + this.jsonProcessorStatus = jsonProcessorStatus; + return this; + } + + public TCAMessageStatusEntityBuilder setJsonProcessorMessage(String jsonProcessorMessage) { + this.jsonProcessorMessage = jsonProcessorMessage; + return this; + } + + public TCAMessageStatusEntityBuilder setDomainFilterStatus(String domainFilterStatus) { + this.domainFilterStatus = domainFilterStatus; + return this; + } + + public TCAMessageStatusEntityBuilder setDomainFilterMessage(String domainFilterMessage) { + this.domainFilterMessage = domainFilterMessage; + return this; + } + + public TCAMessageStatusEntityBuilder setEventNameFilterStatus(String eventNameFilterStatus) { + this.eventNameFilterStatus = eventNameFilterStatus; + return this; + } + + public TCAMessageStatusEntityBuilder setEventNameFilterMessage(String eventNameFilterMessage) { + this.eventNameFilterMessage = eventNameFilterMessage; + return this; + } + + public TCAMessageStatusEntityBuilder setThresholdCalculatorStatus(String thresholdCalculatorStatus) { + this.thresholdCalculatorStatus = thresholdCalculatorStatus; + return this; + } + + public TCAMessageStatusEntityBuilder setThresholdCalculatorMessage(String thresholdCalculatorMessage) { + this.thresholdCalculatorMessage = thresholdCalculatorMessage; + return this; + } + + public TCAMessageStatusEntityBuilder setAlertMessage(String alertMessage) { + this.alertMessage = alertMessage; + return this; + } + + public TCAMessageStatusEntity createTCAMessageStatusEntity() { + return new TCAMessageStatusEntity(this); + } } /**