-/*\r
- * ===============================LICENSE_START======================================\r
- * dcae-analytics\r
- * ================================================================================\r
- * Copyright © 2017 AT&T Intellectual Property. All rights reserved.\r
- * ================================================================================\r
- * Licensed under the Apache License, Version 2.0 (the "License");\r
- * you may not use this file except in compliance with the License.\r
- * You may obtain a copy of the License at\r
- *\r
- * http://www.apache.org/licenses/LICENSE-2.0\r
- *\r
- * Unless required by applicable law or agreed to in writing, software\r
- * distributed under the License is distributed on an "AS IS" BASIS,\r
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
- * See the License for the specific language governing permissions and\r
- * limitations under the License.\r
- * ============================LICENSE_END===========================================\r
- */\r
-\r
-package org.openecomp.dcae.apod.analytics.cdap.tca.settings;\r
-\r
-import com.google.common.base.Objects;\r
-import org.openecomp.dcae.apod.analytics.cdap.common.settings.CDAPAppPreferences;\r
-import org.openecomp.dcae.apod.analytics.common.AnalyticsConstants;\r
-\r
-/**\r
- * <p>\r
- * App Preferences for Analytics TCA (Threshold Crossing Alert) App\r
- * <p>\r
- * @author Rajiv Singla . Creation Date: 10/4/2016.\r
- */\r
-public class TCAAppPreferences implements CDAPAppPreferences {\r
-\r
- private static final long serialVersionUID = 1L;\r
-\r
- // subscriber preferences\r
- protected String subscriberHostName;\r
-\r
- protected Integer subscriberHostPort;\r
-\r
- protected String subscriberTopicName;\r
-\r
- protected String subscriberProtocol;\r
-\r
- protected String subscriberUserName;\r
-\r
- protected String subscriberUserPassword;\r
-\r
- protected String subscriberContentType;\r
-\r
- protected String subscriberConsumerId;\r
-\r
- protected String subscriberConsumerGroup;\r
-\r
- protected Integer subscriberTimeoutMS;\r
-\r
- protected Integer subscriberMessageLimit;\r
-\r
- protected Integer subscriberPollingInterval;\r
-\r
- // publisher preferences\r
- protected String publisherHostName;\r
-\r
- protected Integer publisherHostPort;\r
-\r
- protected String publisherTopicName;\r
-\r
- protected String publisherProtocol;\r
-\r
- protected String publisherUserName;\r
-\r
- protected String publisherUserPassword;\r
-\r
- protected String publisherContentType;\r
-\r
- protected Integer publisherMaxBatchSize;\r
-\r
- protected Integer publisherMaxRecoveryQueueSize;\r
-\r
- protected Integer publisherPollingInterval;\r
-\r
- protected Boolean enableAlertCEFFormat;\r
-\r
-\r
- // A&AI Enrichment\r
-\r
- protected Boolean enableAAIEnrichment;\r
-\r
- protected String aaiEnrichmentHost;\r
-\r
- protected Integer aaiEnrichmentPortNumber;\r
-\r
- protected String aaiEnrichmentProtocol;\r
-\r
- protected String aaiEnrichmentUserName;\r
-\r
- protected String aaiEnrichmentUserPassword;\r
-\r
- protected Boolean aaiEnrichmentIgnoreSSLCertificateErrors;\r
-\r
- protected String aaiVNFEnrichmentAPIPath;\r
-\r
- protected String aaiVMEnrichmentAPIPath;\r
-\r
-\r
- // A&AI Enrichment Proxy\r
-\r
- protected String aaiEnrichmentProxyURL;\r
-\r
- /**\r
- * Default constructor to setup default values for TCA App Preferences\r
- */\r
- public TCAAppPreferences() {\r
-\r
- // subscriber defaults\r
- subscriberPollingInterval = AnalyticsConstants.TCA_DEFAULT_SUBSCRIBER_POLLING_INTERVAL_MS;\r
-\r
- // publisher defaults\r
- publisherMaxBatchSize = AnalyticsConstants.TCA_DEFAULT_PUBLISHER_MAX_BATCH_QUEUE_SIZE;\r
- publisherMaxRecoveryQueueSize = AnalyticsConstants.TCA_DEFAULT_PUBLISHER_MAX_RECOVERY_QUEUE_SIZE;\r
- publisherPollingInterval = AnalyticsConstants.TCA_DEFAULT_PUBLISHER_POLLING_INTERVAL_MS;\r
-\r
- enableAlertCEFFormat = AnalyticsConstants.TCA_DEFAULT_ENABLE_CEF_FORMATTED_ALERT;\r
-\r
- enableAAIEnrichment = AnalyticsConstants.TCA_DEFAULT_ENABLE_AAI_ENRICHMENT;\r
- aaiEnrichmentIgnoreSSLCertificateErrors =\r
- AnalyticsConstants.TCA_DEFAULT_AAI_ENRICHMENT_IGNORE_SSL_CERTIFICATE_ERRORS;\r
- aaiEnrichmentProxyURL = AnalyticsConstants.TCA_DEFAULT_AAI_ENRICHMENT_PROXY_URL;\r
-\r
- }\r
-\r
- public String getSubscriberHostName() {\r
- return subscriberHostName;\r
- }\r
-\r
- public Integer getSubscriberHostPort() {\r
- return subscriberHostPort;\r
- }\r
-\r
- public String getSubscriberTopicName() {\r
- return subscriberTopicName;\r
- }\r
-\r
- public String getSubscriberProtocol() {\r
- return subscriberProtocol;\r
- }\r
-\r
- public String getSubscriberUserName() {\r
- return subscriberUserName;\r
- }\r
-\r
- public String getSubscriberUserPassword() {\r
- return subscriberUserPassword;\r
- }\r
-\r
- public String getSubscriberContentType() {\r
- return subscriberContentType;\r
- }\r
-\r
- public String getSubscriberConsumerId() {\r
- return subscriberConsumerId;\r
- }\r
-\r
- public String getSubscriberConsumerGroup() {\r
- return subscriberConsumerGroup;\r
- }\r
-\r
- public Integer getSubscriberTimeoutMS() {\r
- return subscriberTimeoutMS;\r
- }\r
-\r
- public Integer getSubscriberMessageLimit() {\r
- return subscriberMessageLimit;\r
- }\r
-\r
- public Integer getSubscriberPollingInterval() {\r
- return subscriberPollingInterval;\r
- }\r
-\r
- public String getPublisherHostName() {\r
- return publisherHostName;\r
- }\r
-\r
- public Integer getPublisherHostPort() {\r
- return publisherHostPort;\r
- }\r
-\r
- public String getPublisherTopicName() {\r
- return publisherTopicName;\r
- }\r
-\r
- public String getPublisherProtocol() {\r
- return publisherProtocol;\r
- }\r
-\r
- public String getPublisherUserName() {\r
- return publisherUserName;\r
- }\r
-\r
- public String getPublisherUserPassword() {\r
- return publisherUserPassword;\r
- }\r
-\r
- public String getPublisherContentType() {\r
- return publisherContentType;\r
- }\r
-\r
- public Integer getPublisherMaxBatchSize() {\r
- return publisherMaxBatchSize;\r
- }\r
-\r
- public Integer getPublisherMaxRecoveryQueueSize() {\r
- return publisherMaxRecoveryQueueSize;\r
- }\r
-\r
- public Integer getPublisherPollingInterval() {\r
- return publisherPollingInterval;\r
- }\r
-\r
- public Boolean getEnableAlertCEFFormat() {\r
- return enableAlertCEFFormat;\r
- }\r
-\r
-\r
- public void setSubscriberHostName(String subscriberHostName) {\r
- this.subscriberHostName = subscriberHostName;\r
- }\r
-\r
- public void setSubscriberHostPort(Integer subscriberHostPort) {\r
- this.subscriberHostPort = subscriberHostPort;\r
- }\r
-\r
- public void setSubscriberTopicName(String subscriberTopicName) {\r
- this.subscriberTopicName = subscriberTopicName;\r
- }\r
-\r
- public void setSubscriberProtocol(String subscriberProtocol) {\r
- this.subscriberProtocol = subscriberProtocol;\r
- }\r
-\r
- public void setSubscriberUserName(String subscriberUserName) {\r
- this.subscriberUserName = subscriberUserName;\r
- }\r
-\r
- public void setSubscriberUserPassword(String subscriberUserPassword) {\r
- this.subscriberUserPassword = subscriberUserPassword;\r
- }\r
-\r
- public void setPublisherHostName(String publisherHostName) {\r
- this.publisherHostName = publisherHostName;\r
- }\r
-\r
- public void setPublisherHostPort(Integer publisherHostPort) {\r
- this.publisherHostPort = publisherHostPort;\r
- }\r
-\r
- public void setPublisherTopicName(String publisherTopicName) {\r
- this.publisherTopicName = publisherTopicName;\r
- }\r
-\r
- public void setPublisherProtocol(String publisherProtocol) {\r
- this.publisherProtocol = publisherProtocol;\r
- }\r
-\r
- public void setPublisherUserName(String publisherUserName) {\r
- this.publisherUserName = publisherUserName;\r
- }\r
-\r
- public void setPublisherUserPassword(String publisherUserPassword) {\r
- this.publisherUserPassword = publisherUserPassword;\r
- }\r
-\r
- public Boolean getEnableAAIEnrichment() {\r
- return enableAAIEnrichment;\r
- }\r
-\r
- public String getAaiEnrichmentHost() {\r
- return aaiEnrichmentHost;\r
- }\r
-\r
- public Integer getAaiEnrichmentPortNumber() {\r
- return aaiEnrichmentPortNumber;\r
- }\r
-\r
- public String getAaiEnrichmentProtocol() {\r
- return aaiEnrichmentProtocol;\r
- }\r
-\r
- public String getAaiEnrichmentUserName() {\r
- return aaiEnrichmentUserName;\r
- }\r
-\r
- public String getAaiEnrichmentUserPassword() {\r
- return aaiEnrichmentUserPassword;\r
- }\r
-\r
- public Boolean getAaiEnrichmentIgnoreSSLCertificateErrors() {\r
- return aaiEnrichmentIgnoreSSLCertificateErrors;\r
- }\r
-\r
- public String getAaiVNFEnrichmentAPIPath() {\r
- return aaiVNFEnrichmentAPIPath;\r
- }\r
-\r
- public String getAaiVMEnrichmentAPIPath() {\r
- return aaiVMEnrichmentAPIPath;\r
- }\r
-\r
- public String getAaiEnrichmentProxyURL() {\r
- return aaiEnrichmentProxyURL;\r
- }\r
-\r
- @Override\r
- public String toString() {\r
- return Objects.toStringHelper(this)\r
- .add("subscriberHostName", subscriberHostName)\r
- .add("subscriberHostPort", subscriberHostPort)\r
- .add("subscriberTopicName", subscriberTopicName)\r
- .add("subscriberProtocol", subscriberProtocol)\r
- .add("subscriberUserName", subscriberUserName)\r
- .add("subscriberContentType", subscriberContentType)\r
- .add("subscriberConsumerId", subscriberConsumerId)\r
- .add("subscriberConsumerGroup", subscriberConsumerGroup)\r
- .add("subscriberTimeoutMS", subscriberTimeoutMS)\r
- .add("subscriberMessageLimit", subscriberMessageLimit)\r
- .add("subscriberPollingInterval", subscriberPollingInterval)\r
- .add("publisherHostName", publisherHostName)\r
- .add("publisherHostPort", publisherHostPort)\r
- .add("publisherTopicName", publisherTopicName)\r
- .add("publisherProtocol", publisherProtocol)\r
- .add("publisherUserName", publisherUserName)\r
- .add("publisherContentType", publisherContentType)\r
- .add("publisherMaxBatchSize", publisherMaxBatchSize)\r
- .add("publisherMaxRecoveryQueueSize", publisherMaxRecoveryQueueSize)\r
- .add("publisherPollingInterval", publisherPollingInterval)\r
- .add("enableAlertCEFFormat", enableAlertCEFFormat)\r
- .add("enableAAIEnrichment", enableAAIEnrichment)\r
- .add("aaiEnrichmentHost", aaiEnrichmentHost)\r
- .add("aaiEnrichmentPortNumber", aaiEnrichmentPortNumber)\r
- .add("aaiEnrichmentProtocol", aaiEnrichmentProtocol)\r
- .add("aaiEnrichmentUserName", aaiEnrichmentUserName)\r
- .add("aaiEnrichmentIgnoreSSLCertificateErrors", aaiEnrichmentIgnoreSSLCertificateErrors)\r
- .add("aaiVNFEnrichmentAPIPath", aaiVNFEnrichmentAPIPath)\r
- .add("aaiVMEnrichmentAPIPath", aaiVMEnrichmentAPIPath)\r
- .add("aaiEnrichmentProxyEnabled", aaiEnrichmentProxyURL == null ? "false" : "true")\r
- .toString();\r
- }\r
-}\r
+/*
+ * ===============================LICENSE_START======================================
+ * dcae-analytics
+ * ================================================================================
+ * Copyright © 2017 AT&T Intellectual Property. 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.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============================LICENSE_END===========================================
+ */
+
+package org.onap.dcae.apod.analytics.cdap.tca.settings;
+
+import com.google.common.base.Objects;
+import org.onap.dcae.apod.analytics.cdap.common.settings.CDAPAppPreferences;
+import org.onap.dcae.apod.analytics.common.AnalyticsConstants;
+
+/**
+ * <p>
+ * App Preferences for Analytics TCA (Threshold Crossing Alert) App
+ * <p>
+ * @author Rajiv Singla . Creation Date: 10/4/2016.
+ */
+public class TCAAppPreferences implements CDAPAppPreferences {
+
+ private static final long serialVersionUID = 1L;
+
+ // subscriber preferences
+ protected String subscriberHostName;
+
+ protected Integer subscriberHostPort;
+
+ protected String subscriberTopicName;
+
+ protected String subscriberProtocol;
+
+ protected String subscriberUserName;
+
+ protected String subscriberUserPassword;
+
+ protected String subscriberContentType;
+
+ protected String subscriberConsumerId;
+
+ protected String subscriberConsumerGroup;
+
+ protected Integer subscriberTimeoutMS;
+
+ protected Integer subscriberMessageLimit;
+
+ protected Integer subscriberPollingInterval;
+
+ // publisher preferences
+ protected String publisherHostName;
+
+ protected Integer publisherHostPort;
+
+ protected String publisherTopicName;
+
+ protected String publisherProtocol;
+
+ protected String publisherUserName;
+
+ protected String publisherUserPassword;
+
+ protected String publisherContentType;
+
+ protected Integer publisherMaxBatchSize;
+
+ protected Integer publisherMaxRecoveryQueueSize;
+
+ protected Integer publisherPollingInterval;
+
+ protected Boolean enableAlertCEFFormat;
+
+
+ // A&AI Enrichment
+
+ protected Boolean enableAAIEnrichment;
+
+ protected String aaiEnrichmentHost;
+
+ protected Integer aaiEnrichmentPortNumber;
+
+ protected String aaiEnrichmentProtocol;
+
+ protected String aaiEnrichmentUserName;
+
+ protected String aaiEnrichmentUserPassword;
+
+ protected Boolean aaiEnrichmentIgnoreSSLCertificateErrors;
+
+ protected String aaiVNFEnrichmentAPIPath;
+
+ protected String aaiVMEnrichmentAPIPath;
+
+
+ // A&AI Enrichment Proxy
+
+ protected String aaiEnrichmentProxyURL;
+
+ /**
+ * Default constructor to setup default values for TCA App Preferences
+ */
+ public TCAAppPreferences() {
+
+ // subscriber defaults
+ subscriberPollingInterval = AnalyticsConstants.TCA_DEFAULT_SUBSCRIBER_POLLING_INTERVAL_MS;
+
+ // publisher defaults
+ publisherMaxBatchSize = AnalyticsConstants.TCA_DEFAULT_PUBLISHER_MAX_BATCH_QUEUE_SIZE;
+ publisherMaxRecoveryQueueSize = AnalyticsConstants.TCA_DEFAULT_PUBLISHER_MAX_RECOVERY_QUEUE_SIZE;
+ publisherPollingInterval = AnalyticsConstants.TCA_DEFAULT_PUBLISHER_POLLING_INTERVAL_MS;
+
+ enableAlertCEFFormat = AnalyticsConstants.TCA_DEFAULT_ENABLE_CEF_FORMATTED_ALERT;
+
+ enableAAIEnrichment = AnalyticsConstants.TCA_DEFAULT_ENABLE_AAI_ENRICHMENT;
+ aaiEnrichmentIgnoreSSLCertificateErrors =
+ AnalyticsConstants.TCA_DEFAULT_AAI_ENRICHMENT_IGNORE_SSL_CERTIFICATE_ERRORS;
+ aaiEnrichmentProxyURL = AnalyticsConstants.TCA_DEFAULT_AAI_ENRICHMENT_PROXY_URL;
+
+ }
+
+ public String getSubscriberHostName() {
+ return subscriberHostName;
+ }
+
+ public Integer getSubscriberHostPort() {
+ return subscriberHostPort;
+ }
+
+ public String getSubscriberTopicName() {
+ return subscriberTopicName;
+ }
+
+ public String getSubscriberProtocol() {
+ return subscriberProtocol;
+ }
+
+ public String getSubscriberUserName() {
+ return subscriberUserName;
+ }
+
+ public String getSubscriberUserPassword() {
+ return subscriberUserPassword;
+ }
+
+ public String getSubscriberContentType() {
+ return subscriberContentType;
+ }
+
+ public String getSubscriberConsumerId() {
+ return subscriberConsumerId;
+ }
+
+ public String getSubscriberConsumerGroup() {
+ return subscriberConsumerGroup;
+ }
+
+ public Integer getSubscriberTimeoutMS() {
+ return subscriberTimeoutMS;
+ }
+
+ public Integer getSubscriberMessageLimit() {
+ return subscriberMessageLimit;
+ }
+
+ public Integer getSubscriberPollingInterval() {
+ return subscriberPollingInterval;
+ }
+
+ public String getPublisherHostName() {
+ return publisherHostName;
+ }
+
+ public Integer getPublisherHostPort() {
+ return publisherHostPort;
+ }
+
+ public String getPublisherTopicName() {
+ return publisherTopicName;
+ }
+
+ public String getPublisherProtocol() {
+ return publisherProtocol;
+ }
+
+ public String getPublisherUserName() {
+ return publisherUserName;
+ }
+
+ public String getPublisherUserPassword() {
+ return publisherUserPassword;
+ }
+
+ public String getPublisherContentType() {
+ return publisherContentType;
+ }
+
+ public Integer getPublisherMaxBatchSize() {
+ return publisherMaxBatchSize;
+ }
+
+ public Integer getPublisherMaxRecoveryQueueSize() {
+ return publisherMaxRecoveryQueueSize;
+ }
+
+ public Integer getPublisherPollingInterval() {
+ return publisherPollingInterval;
+ }
+
+ public Boolean getEnableAlertCEFFormat() {
+ return enableAlertCEFFormat;
+ }
+
+
+ public void setSubscriberHostName(String subscriberHostName) {
+ this.subscriberHostName = subscriberHostName;
+ }
+
+ public void setSubscriberHostPort(Integer subscriberHostPort) {
+ this.subscriberHostPort = subscriberHostPort;
+ }
+
+ public void setSubscriberTopicName(String subscriberTopicName) {
+ this.subscriberTopicName = subscriberTopicName;
+ }
+
+ public void setSubscriberProtocol(String subscriberProtocol) {
+ this.subscriberProtocol = subscriberProtocol;
+ }
+
+ public void setSubscriberUserName(String subscriberUserName) {
+ this.subscriberUserName = subscriberUserName;
+ }
+
+ public void setSubscriberUserPassword(String subscriberUserPassword) {
+ this.subscriberUserPassword = subscriberUserPassword;
+ }
+
+ public void setPublisherHostName(String publisherHostName) {
+ this.publisherHostName = publisherHostName;
+ }
+
+ public void setPublisherHostPort(Integer publisherHostPort) {
+ this.publisherHostPort = publisherHostPort;
+ }
+
+ public void setPublisherTopicName(String publisherTopicName) {
+ this.publisherTopicName = publisherTopicName;
+ }
+
+ public void setPublisherProtocol(String publisherProtocol) {
+ this.publisherProtocol = publisherProtocol;
+ }
+
+ public void setPublisherUserName(String publisherUserName) {
+ this.publisherUserName = publisherUserName;
+ }
+
+ public void setPublisherUserPassword(String publisherUserPassword) {
+ this.publisherUserPassword = publisherUserPassword;
+ }
+
+ public Boolean getEnableAAIEnrichment() {
+ return enableAAIEnrichment;
+ }
+
+ public String getAaiEnrichmentHost() {
+ return aaiEnrichmentHost;
+ }
+
+ public Integer getAaiEnrichmentPortNumber() {
+ return aaiEnrichmentPortNumber;
+ }
+
+ public String getAaiEnrichmentProtocol() {
+ return aaiEnrichmentProtocol;
+ }
+
+ public String getAaiEnrichmentUserName() {
+ return aaiEnrichmentUserName;
+ }
+
+ public String getAaiEnrichmentUserPassword() {
+ return aaiEnrichmentUserPassword;
+ }
+
+ public Boolean getAaiEnrichmentIgnoreSSLCertificateErrors() {
+ return aaiEnrichmentIgnoreSSLCertificateErrors;
+ }
+
+ public String getAaiVNFEnrichmentAPIPath() {
+ return aaiVNFEnrichmentAPIPath;
+ }
+
+ public String getAaiVMEnrichmentAPIPath() {
+ return aaiVMEnrichmentAPIPath;
+ }
+
+ public String getAaiEnrichmentProxyURL() {
+ return aaiEnrichmentProxyURL;
+ }
+
+ @Override
+ public String toString() {
+ return Objects.toStringHelper(this)
+ .add("subscriberHostName", subscriberHostName)
+ .add("subscriberHostPort", subscriberHostPort)
+ .add("subscriberTopicName", subscriberTopicName)
+ .add("subscriberProtocol", subscriberProtocol)
+ .add("subscriberUserName", subscriberUserName)
+ .add("subscriberContentType", subscriberContentType)
+ .add("subscriberConsumerId", subscriberConsumerId)
+ .add("subscriberConsumerGroup", subscriberConsumerGroup)
+ .add("subscriberTimeoutMS", subscriberTimeoutMS)
+ .add("subscriberMessageLimit", subscriberMessageLimit)
+ .add("subscriberPollingInterval", subscriberPollingInterval)
+ .add("publisherHostName", publisherHostName)
+ .add("publisherHostPort", publisherHostPort)
+ .add("publisherTopicName", publisherTopicName)
+ .add("publisherProtocol", publisherProtocol)
+ .add("publisherUserName", publisherUserName)
+ .add("publisherContentType", publisherContentType)
+ .add("publisherMaxBatchSize", publisherMaxBatchSize)
+ .add("publisherMaxRecoveryQueueSize", publisherMaxRecoveryQueueSize)
+ .add("publisherPollingInterval", publisherPollingInterval)
+ .add("enableAlertCEFFormat", enableAlertCEFFormat)
+ .add("enableAAIEnrichment", enableAAIEnrichment)
+ .add("aaiEnrichmentHost", aaiEnrichmentHost)
+ .add("aaiEnrichmentPortNumber", aaiEnrichmentPortNumber)
+ .add("aaiEnrichmentProtocol", aaiEnrichmentProtocol)
+ .add("aaiEnrichmentUserName", aaiEnrichmentUserName)
+ .add("aaiEnrichmentIgnoreSSLCertificateErrors", aaiEnrichmentIgnoreSSLCertificateErrors)
+ .add("aaiVNFEnrichmentAPIPath", aaiVNFEnrichmentAPIPath)
+ .add("aaiVMEnrichmentAPIPath", aaiVMEnrichmentAPIPath)
+ .add("aaiEnrichmentProxyEnabled", aaiEnrichmentProxyURL == null ? "false" : "true")
+ .toString();
+ }
+}
Code Review / dcaegen2 / analytics / tca.git / blobdiff