From a50708287e0dc7865a3db603577c92875a122878 Mon Sep 17 00:00:00 2001
From: gautamk189 <gautamkr@hcl.com>
Date: Wed, 6 May 2020 19:49:56 +0530
Subject: Added fix for EXTAPI-197: MSB registration

Issue-ID: EXTAPI-197

Signed-off-by: gautamk189 <gautamkr@hcl.com>
Change-Id: Iea7628481f0ba80b6e5593231c87fec96749b92a
---
 .../java/org/onap/nbi/ServiceRegisterRunner.java   | 137 ---------------------
 1 file changed, 137 deletions(-)
 delete mode 100644 src/main/java/org/onap/nbi/ServiceRegisterRunner.java

(limited to 'src/main/java/org/onap')

diff --git a/src/main/java/org/onap/nbi/ServiceRegisterRunner.java b/src/main/java/org/onap/nbi/ServiceRegisterRunner.java
deleted file mode 100644
index 23fdb25..0000000
--- a/src/main/java/org/onap/nbi/ServiceRegisterRunner.java
+++ /dev/null
@@ -1,137 +0,0 @@
-/**
- * Copyright (c) 2018 Orange
- * <p>
- * 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
- * <p>
- * http://www.apache.org/licenses/LICENSE-2.0
- * <p>
- * 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.
- */
-
-package org.onap.nbi;
-
-import com.google.common.base.Strings;
-import java.net.InetAddress;
-import java.util.HashSet;
-import java.util.Set;
-import org.onap.msb.sdk.discovery.entity.MicroServiceFullInfo;
-import org.onap.msb.sdk.discovery.entity.MicroServiceInfo;
-import org.onap.msb.sdk.discovery.entity.Node;
-import org.onap.msb.sdk.httpclient.msb.MSBServiceClient;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.boot.CommandLineRunner;
-import org.springframework.stereotype.Component;
-
-/**
- * Register this NBI instance with MSB discovery when the app is fully started
- */
-@Component
-public class ServiceRegisterRunner implements CommandLineRunner {
-    private static final Logger logger = LoggerFactory.getLogger(ServiceRegisterRunner.class);
-
-    @Value("${msb.enabled}")
-    private boolean IS_ENABLED;
-
-    @Value("${msb.discovery.host}")
-    private String DISCOVERY_HOST;
-
-    @Value("${msb.discovery.port}")
-    private int DISCOVERY_PORT;
-
-    @Value("${msb.discovery.retry}")
-    private int RETRY;
-
-    @Value("${msb.discovery.retry_interval}")
-    private int RETRY_INTERVAL;
-
-    @Value("${msb.service.host}")
-    private String SERVICE_HOST;
-
-    @Value("${server.port}")
-    private String SERVICE_PORT;
-
-    @Value("${msb.service.name}")
-    private String SERVICE_NAME;
-
-    @Value("${nbi.version}")
-    private String SERVICE_VERSION;
-
-    @Value("${server.servlet.context-path}")
-    private String SERVICE_URL;
-
-    @Value("${msb.service.custom_path}")
-    private String SERVICE_CUSTOM_PATH;
-
-    @Value("${msb.service.protocol}")
-    private String SERVICE_PROTOCOL;
-
-    @Value("${msb.service.visual_range}")
-    private String SERVICE_VISUAL_RANGE;
-
-    @Value("${msb.service.enable_ssl}")
-    private boolean SERVICE_ENABLE_SSL;
-
-    @Override
-    public void run(String... strings) throws Exception {
-        if (!IS_ENABLED) {
-            logger.info("Registration with msb discovery is not enabled");
-            return;
-        }
-
-        MicroServiceInfo msinfo = new MicroServiceInfo();
-        msinfo.setServiceName(SERVICE_NAME);
-        msinfo.setVersion(SERVICE_VERSION);
-        msinfo.setUrl(SERVICE_URL);
-        msinfo.setProtocol(SERVICE_PROTOCOL);
-        msinfo.setVisualRange(SERVICE_VISUAL_RANGE);
-        msinfo.setEnable_ssl(SERVICE_ENABLE_SSL);
-
-        if (!Strings.isNullOrEmpty(SERVICE_CUSTOM_PATH)) {
-            msinfo.setPath(SERVICE_CUSTOM_PATH);
-        }
-
-        Set<Node> nodes = new HashSet<>();
-        Node thisNode = new Node();
-        thisNode.setIp(
-                Strings.isNullOrEmpty(SERVICE_HOST) ? InetAddress.getLocalHost().getHostAddress() : SERVICE_HOST);
-        thisNode.setPort(SERVICE_PORT);
-        thisNode.setCheckType("HTTP");
-        thisNode.setCheckUrl(SERVICE_URL + "/status");
-        nodes.add(thisNode);
-        msinfo.setNodes(nodes);
-
-        logger.info("Registering with msb discovery (" + DISCOVERY_HOST + ":" + DISCOVERY_PORT + "):\n" + " - host: ["
-                + thisNode.getIp() + "]\n" + " - port: [" + thisNode.getPort() + "]\n" + " - name: ["
-                + msinfo.getServiceName() + "]\n" + " - version: [" + msinfo.getVersion() + "]\n" + " - url: ["
-                + msinfo.getUrl() + "]\n" + " - path: [" + msinfo.getPath() + "]\n" + " - protocol: ["
-                + msinfo.getProtocol() + "]g\n" + " - visualRange: [" + msinfo.getVisualRange() + "]\n"
-                + " - enableSSL: [" + SERVICE_ENABLE_SSL + "]\n");
-
-        int attempt = 1;
-        while (attempt <= RETRY) {
-            try {
-                logger.info("Registration with msb discovery (attempt {}/{})", attempt, RETRY);
-                MSBServiceClient msbClient = new MSBServiceClient(DISCOVERY_HOST, DISCOVERY_PORT);
-                MicroServiceFullInfo microServiceFullInfo = msbClient.registerMicroServiceInfo(msinfo);
-                logger.debug("Registration with msb discovery done, microServiceFullInfo = {}",
-                        microServiceFullInfo.toString());
-                break;
-            } catch (Exception ex) {
-                logger.warn("Registration with msb discovery (attempt {}/{}) FAILED.", attempt, RETRY);
-                attempt += 1;
-                if (attempt <= RETRY) {
-                    logger.warn("Sleep {}ms", RETRY_INTERVAL);
-                    Thread.sleep(RETRY_INTERVAL);
-                }
-            }
-        }
-    }
-}
-- 
cgit 1.2.3-korg