X-Git-Url: https://gerrit.onap.org/r/gitweb?p=aai%2Fesr-server.git;a=blobdiff_plain;f=esr-mgr%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Faai%2Fesr%2Fexternalservice%2Fmsb%2FMsbHelper.java;h=41c9d915bd79d4d31baf73592a6adb830d576c63;hp=5f0d6b9e74388a79a794fc88089e5537e3f5fcd5;hb=4cb06783a36e3fd3323a45bc0ba370f737574bc0;hpb=1c8188bacbe7a7ddff2387758c1d9dbfd5f2fcc0 diff --git a/esr-mgr/src/main/java/org/onap/aai/esr/externalservice/msb/MsbHelper.java b/esr-mgr/src/main/java/org/onap/aai/esr/externalservice/msb/MsbHelper.java index 5f0d6b9..41c9d91 100644 --- a/esr-mgr/src/main/java/org/onap/aai/esr/externalservice/msb/MsbHelper.java +++ b/esr-mgr/src/main/java/org/onap/aai/esr/externalservice/msb/MsbHelper.java @@ -16,41 +16,52 @@ package org.onap.aai.esr.externalservice.msb; import java.net.InetAddress; +import java.net.UnknownHostException; import java.util.HashSet; import java.util.Set; - +import org.onap.aai.esr.exception.ExceptionUtil; +import org.onap.msb.sdk.discovery.common.RouteException; import org.onap.msb.sdk.discovery.entity.MicroServiceInfo; import org.onap.msb.sdk.httpclient.msb.MSBServiceClient; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.onap.msb.sdk.discovery.entity.Node; public class MsbHelper { - private MSBServiceClient msbClient; + private MSBServiceClient msbClient; + + private static final Logger LOG = LoggerFactory.getLogger(MsbHelper.class); + + public MsbHelper(MSBServiceClient msbClient) { + super(); + this.msbClient = msbClient; + } - public MsbHelper(MSBServiceClient msbClient) { - super(); - this.msbClient = msbClient; - } + public void registerMsb() throws RouteException { - public void registerMsb() throws Exception { + MicroServiceInfo msinfo = new MicroServiceInfo(); - MicroServiceInfo msinfo = new MicroServiceInfo(); + msinfo.setServiceName("aai-esr-server"); + msinfo.setVersion("v1"); + msinfo.setUrl("/api/aai-esr-server/v1"); + msinfo.setProtocol("REST"); + msinfo.setVisualRange("0|1"); - msinfo.setServiceName("aai-esr-server"); - msinfo.setVersion("v1"); - msinfo.setUrl("/api/aai-esr-server/v1"); - msinfo.setProtocol("REST"); - msinfo.setVisualRange("0|1"); - - Set nodes = new HashSet<>(); - Node node1 = new Node(); - node1.setIp(InetAddress.getLocalHost().getHostAddress()); - node1.setPort("9518"); - nodes.add(node1); - msinfo.setNodes(nodes); - msbClient.registerMicroServiceInfo(msinfo, false); - } + Set nodes = new HashSet<>(); + Node node1 = new Node(); + try { + node1.setIp(InetAddress.getLocalHost().getHostAddress()); + } catch (UnknownHostException e) { + LOG.error("Got localhost failed when register service to MSB!", e); + throw ExceptionUtil.buildExceptionResponse(e.getMessage()); + } + node1.setPort("9518"); + nodes.add(node1); + msinfo.setNodes(nodes); + msbClient.registerMicroServiceInfo(msinfo, false); + } }