- ObjectMapper mapper = new ObjectMapper();\r
- String content = mapper.writeValueAsString(entity);\r
- HttpPost httpPost = new HttpPost(\r
- MicroServiceConfig.getMsbServerAddr() + "/api/microservices/v1/services?createOrUpdate=true");\r
- HttpGet httpGet = new HttpGet(\r
- MicroServiceConfig.getMsbServerAddr() + "/api/microservices/v1/services/");\r
- if (StringUtils.isNotEmpty(content)) {\r
- httpPost.setEntity(new ByteArrayEntity(content.getBytes()));\r
- }\r
- this.setHeader(httpPost);\r
- this.setHeader(httpGet);\r
- HttpResponse response;\r
- try {\r
- response = httpClient.execute(httpPost);\r
- } catch (Exception e) {\r
- log.warn("Registering the service to the bus failure", e);\r
- return false;\r
- }\r
- HttpResponse responseGet = null;\r
- try {\r
- responseGet = httpClient.execute(httpPost);\r
- log.info("all service:" + EntityUtils.toString(responseGet.getEntity()));\r
- } catch (Exception e) {\r
- if (responseGet != null) {\r
- log.info(responseGet.getStatusLine().getReasonPhrase());\r
- }\r
- log.warn("query all service failure", e);\r
- }\r
- if (response.getStatusLine().getStatusCode() == AlarmConst.MICRO_SERVICE_STATUS_SUCCESS) {\r
- log.info("Registration successful service to the bus :" + EntityUtils.toString(response.getEntity()));\r
- return true;\r
- } else {\r
- log.warn(\r
- "Registering the service to the bus failure:" + response.getStatusLine().getStatusCode() + " " +\r
- response.getStatusLine().getReasonPhrase());\r
- return false;\r
- }\r
- } catch (IOException e) {\r
- log.warn("ServiceRegisterEntity:" + entity + " parse failed", e);\r
- } finally {\r
- try {\r
- httpClient.close();\r
- } catch (IOException e) {\r
- log.warn("At the time of registering service httpclient close failure", e);\r
- }\r
+ log.info("msbServerAddr:" + MicroServiceConfig.getMsbServerAddr());\r
+ log.info("entity:" + entity);\r
+ MicroserviceBusRest resourceserviceproxy = ConsumerFactory.createConsumer(\r
+ MicroServiceConfig.getMsbServerAddr(), config, MicroserviceBusRest.class);\r
+ resourceserviceproxy.registerServce("false", entity);\r
+ } catch (Exception error) {\r
+ log.error("microservice register failed!" + error.getMessage());\r
+ return false;\r