import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
+import com.alibaba.fastjson.JSON;
import com.google.gson.Gson;
@Component
public void register() {
try {
String vfcAdaptorInfoJsonStr = readVfcAdaptorInfoFromJsonFile();
- MicroServiceInfo msinfo = gson.fromJson(vfcAdaptorInfoJsonStr, MicroServiceInfo.class);
+// MicroServiceInfo msinfo = gson.fromJson(vfcAdaptorInfoJsonStr, MicroServiceInfo.class);
+
+ JSON json = com.alibaba.fastjson.JSON.parseObject(vfcAdaptorInfoJsonStr);
+ MicroServiceInfo msinfo = com.alibaba.fastjson.JSON.toJavaObject(json , MicroServiceInfo.class);
MSBServiceClient msbClient = new MSBServiceClient(adaptorEnv.getMsbIp(), adaptorEnv.getMsbPort());
MicroServiceFullInfo microServiceInfo = msbClient.registerMicroServiceInfo(msinfo);
logger.info("Registered service response info is " + microServiceInfo.toString());
- } catch (IOException e) {
- logger.error("Failed to read vfcadaptor info! ", e);
} catch (RouteException e) {
- logger.error("Failed to register nokia vnfm driver! ", e);
+ logger.error("RouteException Failed to register nokia vnfm driver! ", e);
+ } catch (IOException e) {
+ logger.error("IOException Failed to register nokia vnfm driver! ", e);
}
}
public String getServiceUrlInMsbBySeriveNameAndPort(String serviceName, String version) throws RouteException
{
+ String serviceUrl = null;
MSBServiceClient msbClient = new MSBServiceClient(adaptorEnv.getMsbIp(), adaptorEnv.getMsbPort());
MicroServiceFullInfo microServiceInfo = msbClient.queryMicroServiceInfo(serviceName, version);
if(null == microServiceInfo)
{
logger.error("There is no service in MSB for serviceName = {} and version = {}", serviceName, version);
}
-
- String serviceUrl = microServiceInfo.getUrl();
- logger.info("Service Url in MSB for serviceName = {} and version = {} is {}", serviceName, version, serviceUrl);
-
- return serviceUrl;
+ else
+ {
+ serviceUrl = microServiceInfo.getUrl();
+ logger.info("Service Url in MSB for serviceName = {} and version = {} is {}", serviceName, version, serviceUrl);
+ }
+ return serviceUrl;
}
public void setAdaptorEnv(AdaptorEnv env) {
this.adaptorEnv = env;
}
+
+ public static final void main(String[] args) {
+ MsbMgmrImpl impl = new MsbMgmrImpl();
+ impl.register();
+ }
}