diff options
author | Guangrong Fu <fu.guangrong@zte.com.cn> | 2017-09-02 18:31:37 +0800 |
---|---|---|
committer | Guangrong Fu <fu.guangrong@zte.com.cn> | 2017-09-02 18:31:37 +0800 |
commit | d22b892d315de0fc5710653540472b82c2a21584 (patch) | |
tree | 17616bc535a2445b58cb22fe5366e8fc61df3243 /rulemgt/src/main/java | |
parent | 4637e303f4c1d65a463a920444a6274af3b78b39 (diff) |
Using MSB Java SDK for registration
Use the MSB Java SDK for service registration
Change-Id: I4f74deb1db23c79fadfbb6ae44ac716af9e79725
Issue-ID: HOLMES-48
Signed-off-by: Guangrong Fu <fu.guangrong@zte.com.cn>
Diffstat (limited to 'rulemgt/src/main/java')
-rw-r--r-- | rulemgt/src/main/java/org/onap/holmes/rulemgt/RuleActiveApp.java | 51 |
1 files changed, 31 insertions, 20 deletions
diff --git a/rulemgt/src/main/java/org/onap/holmes/rulemgt/RuleActiveApp.java b/rulemgt/src/main/java/org/onap/holmes/rulemgt/RuleActiveApp.java index 8dc697c..0aeb584 100644 --- a/rulemgt/src/main/java/org/onap/holmes/rulemgt/RuleActiveApp.java +++ b/rulemgt/src/main/java/org/onap/holmes/rulemgt/RuleActiveApp.java @@ -16,21 +16,27 @@ package org.onap.holmes.rulemgt; +import static jdk.nashorn.internal.runtime.regexp.joni.Config.log; + import io.dropwizard.setup.Environment; -import java.io.IOException; +import java.util.HashSet; +import java.util.Set; import lombok.extern.slf4j.Slf4j; -import org.onap.holmes.common.dropwizard.ioc.bundle.IOCApplication; -import org.onap.holmes.common.api.entity.ServiceRegisterEntity; import org.onap.holmes.common.config.MicroServiceConfig; +import org.onap.holmes.common.dropwizard.ioc.bundle.IOCApplication; +import org.onap.holmes.common.exception.CorrelationException; import org.onap.holmes.common.utils.MSBRegisterUtil; +import org.onap.holmes.rulemgt.resources.RuleMgtResources; +import org.onap.msb.sdk.discovery.entity.MicroServiceInfo; +import org.onap.msb.sdk.discovery.entity.Node; @Slf4j -public class RuleActiveApp extends IOCApplication< RuleAppConfig > { +public class RuleActiveApp extends IOCApplication<RuleAppConfig> { - public static void main( String[] args ) throws Exception { - new RuleActiveApp().run( args ); + public static void main(String[] args) throws Exception { + new RuleActiveApp().run(args); } - + @Override public String getName() { return "Holmes Rule Management ActiveApp APP "; @@ -40,22 +46,27 @@ public class RuleActiveApp extends IOCApplication< RuleAppConfig > { public void run(RuleAppConfig configuration, Environment environment) throws Exception { super.run(configuration, environment); + environment.jersey().register(new RuleMgtResources()); try { - new MSBRegisterUtil().register(initServiceEntity()); - } catch (IOException e) { - log.warn("Micro service registry httpclient close failure",e); + new MSBRegisterUtil().register2Msb(createMicroServiceInfo()); + } catch (CorrelationException e) { + log.warn(e.getMessage(), e); } - } - private ServiceRegisterEntity initServiceEntity() { - ServiceRegisterEntity serviceRegisterEntity = new ServiceRegisterEntity(); - serviceRegisterEntity.setServiceName("holmes-rule-mgmt"); - serviceRegisterEntity.setProtocol("REST"); - serviceRegisterEntity.setVersion("v1"); - serviceRegisterEntity.setUrl("/onapapi/holmes-rule-mgmt/v1"); - serviceRegisterEntity.setSingleNode(MicroServiceConfig.getServiceIp(), "9101", 0); - serviceRegisterEntity.setVisualRange("1|0"); - return serviceRegisterEntity; + private MicroServiceInfo createMicroServiceInfo() { + MicroServiceInfo msinfo = new MicroServiceInfo(); + msinfo.setServiceName("holmes-rule-mgmt"); + msinfo.setVersion("v1"); + msinfo.setUrl("/onapapi/holmes-rule-mgmt/v1"); + msinfo.setProtocol("REST"); + msinfo.setVisualRange("0|1"); + Set<Node> nodes = new HashSet<>(); + Node node = new Node(); + node.setIp(MicroServiceConfig.getServiceIp()); + node.setPort("9101"); + nodes.add(node); + msinfo.setNodes(nodes); + return msinfo; } } |