1 files changed, 193 insertions, 193 deletions
diff --git a/dcae-analytics-dmaap/src/main/java/org/openecomp/dcae/apod/analytics/dmaap/domain/config/DMaaPMRBaseConfig.java b/dcae-analytics-dmaap/src/main/java/org/openecomp/dcae/apod/analytics/dmaap/domain/config/DMaaPMRBaseConfig.java
index d732c9f..32a4357 100644
--- a/dcae-analytics-dmaap/src/main/java/org/openecomp/dcae/apod/analytics/dmaap/domain/config/DMaaPMRBaseConfig.java
+++ b/dcae-analytics-dmaap/src/main/java/org/openecomp/dcae/apod/analytics/dmaap/domain/config/DMaaPMRBaseConfig.java
@@ -1,193 +1,193 @@
-/*
- * ===============================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.openecomp.dcae.apod.analytics.dmaap.domain.config;
-
-import com.google.common.base.Objects;
-import org.openecomp.dcae.apod.analytics.common.exception.DCAEAnalyticsRuntimeException;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.Locale;
-
-import static org.openecomp.dcae.apod.analytics.common.utils.HTTPUtils.JSON_APPLICATION_TYPE;
-
-/**
- * <p>
- *      Contains common parameters for both DMaaP Message Router Publisher and Subscriber Configs
- * <p>
- * @author Rajiv Singla . Creation Date: 10/12/2016.
- */
-public abstract class DMaaPMRBaseConfig implements DMaaPMRConfig {
-
-    protected static final Logger LOG = LoggerFactory.getLogger(DMaaPMRBaseConfig.class);
-
-    protected String hostName;
-    protected Integer portNumber;
-    protected String topicName;
-    protected String protocol;
-    protected String userName;
-    protected String userPassword;
-    protected String contentType;
-
-    /**
-     * Provides host name e.g. mrlocal-mtnjftle01.homer.com
-     *
-     * @return host name
-     */
-    public String getHostName() {
-        return hostName;
-    }
-
-
-    /**
-     * Provides Port Number of DMaaP MR Topic Host. Defaults to 80
-     *
-     * @return host port number
-     */
-    public Integer getPortNumber() {
-        return portNumber;
-    }
-
-    /**
-     * Provides topic name e.g. com.dcae.dmaap.mtnje2.DcaeTestVES
-     *
-     * @return topic name
-     */
-    public String getTopicName() {
-        return topicName;
-    }
-
-    /**
-     * Provides protocol type e.g. http or https
-     *
-     * @return protocol type
-     */
-    public String getProtocol() {
-        return protocol;
-    }
-
-    /**
-     * Provides content type e.g. application/json
-     *
-     * @return content type
-     */
-    public String getContentType() {
-        return contentType;
-    }
-
-
-    /**
-     * Provides User name for the DMaaP MR Topic authentication
-     *
-     * @return user name
-     */
-    public String getUserName() {
-        return userName;
-    }
-
-    /**
-     * Provides User password for the DMaaP MR Topic authentication
-     *
-     * @return user Password
-     */
-    public String getUserPassword() {
-        return userPassword;
-    }
-
-
-    /**
-     * Trims, adjusts casing and validates user input String for protocol selection
-     *
-     * @param protocol - User input for protocol String
-     * @return - network protocol e.g http or https
-     */
-    protected static String normalizeValidateProtocol(final String protocol) {
-        // validate that only http and https are supported protocols are Supported for DMaaP MR
-        String normalizedProtocolString = protocol.trim().toLowerCase(Locale.ENGLISH);
-        if (normalizedProtocolString.isEmpty() ||
-                !("http".equals(normalizedProtocolString) || "https".equals(normalizedProtocolString))) {
-
-            final String errorMessage =
-                    "Unsupported protocol selection. Only HTTPS and HTTPS are currently supported for DMaaP MR";
-
-            throw new DCAEAnalyticsRuntimeException(errorMessage, LOG, new IllegalArgumentException(errorMessage));
-        }
-        return normalizedProtocolString;
-    }
-
-
-    /**
-     * Trims, adjust casing and validates content type is supported by DMaaP.
-     *
-     * NOTE: DMaaP currently only support application/json content type
-     *
-     * @param contentType content type that needs to checked for DMaaP MR support
-     * @return true if content type is supported by DMaaP MR
-     */
-    protected static String normalizeValidateContentType(final String contentType) {
-        // Current DMaaP MR is only supporting "application/json" content type
-        String normalizedContentType = contentType.trim().toLowerCase(Locale.ENGLISH);
-        final boolean isSupported = contentType.equals(JSON_APPLICATION_TYPE);
-        if (!isSupported) {
-            final String errorMessage =
-                    "Unsupported content type selection. Only application/json is currently supported for DMaaP MR";
-
-            throw new DCAEAnalyticsRuntimeException(errorMessage, LOG, new IllegalArgumentException(errorMessage));
-        }
-        return normalizedContentType;
-    }
-
-
-    @Override
-    public boolean equals(Object o) {
-        if (this == o) {
-            return true;
-        }
-        if (!(o instanceof DMaaPMRBaseConfig)) {
-            return false;
-        }
-        DMaaPMRBaseConfig that = (DMaaPMRBaseConfig) o;
-        return Objects.equal(hostName, that.hostName) &&
-                Objects.equal(portNumber, that.portNumber) &&
-                Objects.equal(topicName, that.topicName) &&
-                Objects.equal(protocol, that.protocol) &&
-                Objects.equal(userName, that.userName) &&
-                Objects.equal(userPassword, that.userPassword) &&
-                Objects.equal(contentType, that.contentType);
-    }
-
-    @Override
-    public int hashCode() {
-        return Objects.hashCode(hostName, portNumber, topicName, protocol, userName, userPassword, contentType);
-    }
-
-    @Override
-    public String toString() {
-        return Objects.toStringHelper(this)
-                .add("hostName", hostName)
-                .add("portNumber", portNumber)
-                .add("topicName", topicName)
-                .add("protocol", protocol)
-                .add("userName", userName)
-                .add("contentType", contentType)
-                .toString();
-    }
-}
+/*
+ * ===============================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.openecomp.dcae.apod.analytics.dmaap.domain.config;
+
+import com.google.common.base.Objects;
+import org.openecomp.dcae.apod.analytics.common.exception.DCAEAnalyticsRuntimeException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.Locale;
+
+import static org.openecomp.dcae.apod.analytics.common.utils.HTTPUtils.JSON_APPLICATION_TYPE;
+
+/**
+ * <p>
+ *      Contains common parameters for both DMaaP Message Router Publisher and Subscriber Configs
+ * <p>
+ * @author Rajiv Singla . Creation Date: 10/12/2016.
+ */
+public abstract class DMaaPMRBaseConfig implements DMaaPMRConfig {
+
+    protected static final Logger LOG = LoggerFactory.getLogger(DMaaPMRBaseConfig.class);
+
+    protected String hostName;
+    protected Integer portNumber;
+    protected String topicName;
+    protected String protocol;
+    protected String userName;
+    protected String userPassword;
+    protected String contentType;
+
+    /**
+     * Provides host name e.g. mrlocal-mtnjftle01.homer.com
+     *
+     * @return host name
+     */
+    public String getHostName() {
+        return hostName;
+    }
+
+
+    /**
+     * Provides Port Number of DMaaP MR Topic Host. Defaults to 80
+     *
+     * @return host port number
+     */
+    public Integer getPortNumber() {
+        return portNumber;
+    }
+
+    /**
+     * Provides topic name e.g. com.dcae.dmaap.mtnje2.DcaeTestVES
+     *
+     * @return topic name
+     */
+    public String getTopicName() {
+        return topicName;
+    }
+
+    /**
+     * Provides protocol type e.g. http or https
+     *
+     * @return protocol type
+     */
+    public String getProtocol() {
+        return protocol;
+    }
+
+    /**
+     * Provides content type e.g. application/json
+     *
+     * @return content type
+     */
+    public String getContentType() {
+        return contentType;
+    }
+
+
+    /**
+     * Provides User name for the DMaaP MR Topic authentication
+     *
+     * @return user name
+     */
+    public String getUserName() {
+        return userName;
+    }
+
+    /**
+     * Provides User password for the DMaaP MR Topic authentication
+     *
+     * @return user Password
+     */
+    public String getUserPassword() {
+        return userPassword;
+    }
+
+
+    /**
+     * Trims, adjusts casing and validates user input String for protocol selection
+     *
+     * @param protocol - User input for protocol String
+     * @return - network protocol e.g http or https
+     */
+    protected static String normalizeValidateProtocol(final String protocol) {
+        // validate that only http and https are supported protocols are Supported for DMaaP MR
+        String normalizedProtocolString = protocol.trim().toLowerCase(Locale.ENGLISH);
+        if (normalizedProtocolString.isEmpty() ||
+                !("http".equals(normalizedProtocolString) || "https".equals(normalizedProtocolString))) {
+
+            final String errorMessage =
+                    "Unsupported protocol selection. Only HTTPS and HTTPS are currently supported for DMaaP MR";
+
+            throw new DCAEAnalyticsRuntimeException(errorMessage, LOG, new IllegalArgumentException(errorMessage));
+        }
+        return normalizedProtocolString;
+    }
+
+
+    /**
+     * Trims, adjust casing and validates content type is supported by DMaaP.
+     *
+     * NOTE: DMaaP currently only support application/json content type
+     *
+     * @param contentType content type that needs to checked for DMaaP MR support
+     * @return true if content type is supported by DMaaP MR
+     */
+    protected static String normalizeValidateContentType(final String contentType) {
+        // Current DMaaP MR is only supporting "application/json" content type
+        String normalizedContentType = contentType.trim().toLowerCase(Locale.ENGLISH);
+        final boolean isSupported = contentType.equals(JSON_APPLICATION_TYPE);
+        if (!isSupported) {
+            final String errorMessage =
+                    "Unsupported content type selection. Only application/json is currently supported for DMaaP MR";
+
+            throw new DCAEAnalyticsRuntimeException(errorMessage, LOG, new IllegalArgumentException(errorMessage));
+        }
+        return normalizedContentType;
+    }
+
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) {
+            return true;
+        }
+        if (!(o instanceof DMaaPMRBaseConfig)) {
+            return false;
+        }
+        DMaaPMRBaseConfig that = (DMaaPMRBaseConfig) o;
+        return Objects.equal(hostName, that.hostName) &&
+                Objects.equal(portNumber, that.portNumber) &&
+                Objects.equal(topicName, that.topicName) &&
+                Objects.equal(protocol, that.protocol) &&
+                Objects.equal(userName, that.userName) &&
+                Objects.equal(userPassword, that.userPassword) &&
+                Objects.equal(contentType, that.contentType);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hashCode(hostName, portNumber, topicName, protocol, userName, userPassword, contentType);
+    }
+
+    @Override
+    public String toString() {
+        return Objects.toStringHelper(this)
+                .add("hostName", hostName)
+                .add("portNumber", portNumber)
+                .add("topicName", topicName)
+                .add("protocol", protocol)
+                .add("userName", userName)
+                .add("contentType", contentType)
+                .toString();
+    }
+}