-/**
+/*
* Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
*
* Licensed under the Apache License, Version 2.0 (the "License");
*/
package org.onap.vfc.nfvo.emsdriver;
+import com.fasterxml.jackson.annotation.JsonInclude;
import io.dropwizard.Application;
import io.dropwizard.assets.AssetsBundle;
import io.dropwizard.jetty.HttpConnectorFactory;
import io.dropwizard.setup.Environment;
import io.swagger.jaxrs.config.BeanConfig;
import io.swagger.jaxrs.listing.ApiListingResource;
-
-import java.net.InetAddress;
-import java.net.UnknownHostException;
-import java.util.ArrayList;
-import java.util.List;
-
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.onap.vfc.nfvo.emsdriver.commons.constant.Constant;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.FileSystemXmlApplicationContext;
-import com.fasterxml.jackson.annotation.JsonInclude;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.util.ArrayList;
+import java.util.List;
public class EmsDriverApplication extends Application<EmsDriverConfiguration> {
-
- protected static Log log = LogFactory.getLog(EmsDriverApplication.class);
- private ApplicationContext context = null;
-
- public static void main(String[] args) throws Exception {
+
+ protected static Log log = LogFactory.getLog(EmsDriverApplication.class);
+ private ApplicationContext context = null;
+
+ public static void main(String[] args) throws Exception {
+ log.info("EmsDriverApplication start");
new EmsDriverApplication().run(args);
+ log.info("EmsDriverApplication start sucess");
}
@Override
@Override
public void initialize(Bootstrap<EmsDriverConfiguration> bootstrap) {
// nothing to do yet
- context = new FileSystemXmlApplicationContext("file:" + Constant.SYS_CFG+ "spring.xml");
- bootstrap.addBundle(new AssetsBundle("/api-doc", "/api-doc", "index.html", "api-doc"));
+ context = new FileSystemXmlApplicationContext("file:" + Constant.SYS_CFG + "spring.xml");
+ bootstrap.addBundle(new AssetsBundle("/api-doc", "/api-doc", "index.html", "api-doc"));
}
@Override
- public void run(EmsDriverConfiguration configuration,Environment environment) {
- // register CommandResource
- environment.jersey().register(new CommandResource());
- MsbConfiguration.setMsbAddress(configuration.getMsbAddress());
- //MSB register
- String registerFlag = configuration.getAutoServiceRegister();
- if("false".equalsIgnoreCase(registerFlag)){
- this.msbRegisteEmsDriverService(configuration);
- }
- //Start workThread
- this.startThread();
- initSwaggerConfig(environment, configuration);
+ public void run(EmsDriverConfiguration configuration, Environment environment) {
+ // register CommandResource
+ environment.jersey().register(new CommandResource());
+ MsbConfiguration.setMsbAddress(configuration.getMsbAddress());
+ //MSB register
+ String registerFlag = configuration.getAutoServiceRegister();
+ if ("false".equalsIgnoreCase(registerFlag)) {
+ this.msbRegisteEmsDriverService(configuration);
+ }
+ //Start workThread
+ this.startThread();
+ initSwaggerConfig(environment, configuration);
}
-
- private void startThread(){
- String[] allThreadName = context.getBeanNamesForType(DriverThread.class);
- log.info("worker num :" + allThreadName.length);
- for (String threadName : allThreadName) {
- DriverThread thread = (DriverThread) context.getBean(threadName);
- if (thread == null) {
- log.error(threadName + "Thread start error,system exit");
- System.exit(1);
- }else{
- thread.setName(threadName);
- thread.start();
- }
-
- }
+
+ private void startThread() {
+ String[] allThreadName = context.getBeanNamesForType(DriverThread.class);
+ log.info("worker num :" + allThreadName.length);
+ for (String threadName : allThreadName) {
+ DriverThread thread = (DriverThread) context.getBean(threadName);
+ if (thread == null) {
+ log.error(threadName + "Thread start error,system exit");
+ System.exit(1);
+ } else {
+ thread.setName(threadName);
+ thread.start();
+ }
+
+ }
}
+
// init swagger
- private void initSwaggerConfig(Environment environment, EmsDriverConfiguration configuration)
- {
+ private void initSwaggerConfig(Environment environment, EmsDriverConfiguration configuration) {
environment.jersey().register(new ApiListingResource());
environment.getObjectMapper().setSerializationInclusion(JsonInclude.Include.NON_NULL);
config.setVersion("1.0.0");
config.setResourcePackage("org.onap.vfc.nfvo.emsdriver.northbound.service");
//swagger rest api basepath
- SimpleServerFactory simpleServerFactory = (SimpleServerFactory)configuration.getServerFactory();
+ SimpleServerFactory simpleServerFactory = (SimpleServerFactory) configuration.getServerFactory();
String basePath = simpleServerFactory.getApplicationContextPath();
String rootPath = simpleServerFactory.getJerseyRootPath().get();
rootPath = rootPath.substring(0, rootPath.indexOf("/*"));
basePath = basePath.equals("/") ? rootPath : (new StringBuilder()).append(basePath).append(rootPath).toString();
config.setBasePath(basePath);
- config.setScan(true);
+ config.setScan(true);
+ }
+
+ private void msbRegisteEmsDriverService(EmsDriverConfiguration configuration) {
+ SimpleServerFactory simpleServerFactory = (SimpleServerFactory) configuration.getServerFactory();
+ HttpConnectorFactory connector = (HttpConnectorFactory) simpleServerFactory.getConnector();
+ MsbRegisterVo registerVo = new MsbRegisterVo();
+ ServiceNodeVo serviceNode = new ServiceNodeVo();
+ String ip = "";
+ try {
+ ip = InetAddress.getLocalHost().getHostAddress();
+ } catch (UnknownHostException e) {
+ log.error("Unable to get host ip: ", e);
+ }
+ if (ip.equals("")) {
+ ip = connector.getBindHost();
+ }
+ serviceNode.setIp(ip);
+ serviceNode.setPort(String.valueOf(connector.getPort()));
+ serviceNode.setTtl(0);
+
+ List<ServiceNodeVo> nodeList = new ArrayList<ServiceNodeVo>();
+ nodeList.add(serviceNode);
+ registerVo.setServiceName("emsdriver");
+ registerVo.setUrl("/api/emsdriver/v1");
+ registerVo.setNodes(nodeList);
+
+ MsbRestServiceProxy.registerService(registerVo);
+ log.info("register vfc-emsdriver service to msb finished.");
+
}
-
- private void msbRegisteEmsDriverService(EmsDriverConfiguration configuration) {
- SimpleServerFactory simpleServerFactory = (SimpleServerFactory)configuration.getServerFactory();
- HttpConnectorFactory connector = (HttpConnectorFactory)simpleServerFactory.getConnector();
- MsbRegisterVo registerVo = new MsbRegisterVo();
- ServiceNodeVo serviceNode = new ServiceNodeVo();
- String ip = "";
- try {
- ip = InetAddress.getLocalHost().getHostAddress();
- } catch (UnknownHostException e) {
- log.error("Unable to get host ip: ",e);
- }
- if(ip.equals("")){
- ip = connector.getBindHost();
- }
- serviceNode.setIp(ip);
- serviceNode.setPort(String.valueOf(connector.getPort()));
- serviceNode.setTtl(0);
-
- List<ServiceNodeVo> nodeList = new ArrayList<ServiceNodeVo>();
- nodeList.add(serviceNode);
- registerVo.setServiceName("emsdriver");
- registerVo.setUrl("/api/emsdriver/v1");
- registerVo.setNodes(nodeList);
-
- MsbRestServiceProxy.registerService(registerVo);
- log.info("register vfc-emsdriver service to msb finished.");
-
- }
-
-
+
+
}
Code Review / vfc / nfvo / driver / ems.git / blobdiff