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=f38535074855d5683ef52c7621931750ad0385d2;hb=4cb06783a36e3fd3323a45bc0ba370f737574bc0;hpb=fa6dd60a45a093205ae55065f6de044c91493e60 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 f385350..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("animals"); - msinfo.setVersion("v1"); - msinfo.setUrl("/api/rpc/v1"); - msinfo.setProtocol("REST"); - msinfo.setVisualRange("0|1"); - - Set nodes = new HashSet<>(); - Node node1 = new Node(); - node1.setIp(InetAddress.getLocalHost().getHostAddress()); - node1.setPort("9090"); - 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); + } }