import org.apache.commons.lang3.StringUtils;\r
import org.apache.http.HttpResponse;\r
import org.apache.http.client.methods.HttpPost;\r
+import org.apache.http.client.methods.HttpRequestBase;\r
import org.apache.http.entity.ByteArrayEntity;\r
import org.apache.http.impl.client.CloseableHttpClient;\r
import org.apache.http.impl.client.HttpClients;\r
ObjectMapper mapper = new ObjectMapper();\r
String content = mapper.writeValueAsString(entity);\r
HttpPost httpPost = new HttpPost("http://" + MicroServiceConfig.getMsbServerAddr()\r
- + ":8086/openoapi/microservices/v1/services?createOrUpdate=false");\r
+ + ":8086/api/microservices/v1/services?createOrUpdate=false");\r
if (StringUtils.isNotEmpty(content)) {\r
httpPost.setEntity(new ByteArrayEntity(content.getBytes()));\r
}\r
+ this.setHeader(httpPost);\r
HttpResponse response;\r
try {\r
response = httpClient.execute(httpPost);\r
log.info("Registration successful service to the bus :" + response.getEntity());\r
return true;\r
} else {\r
- log.warn("Registering the service to the bus failure:"+response.getStatusLine().getStatusCode()+" "+\r
- response.getStatusLine().getReasonPhrase()+response.getStatusLine().getProtocolVersion());\r
+ log.warn(\r
+ "Registering the service to the bus failure:" + response.getStatusLine().getStatusCode() + " " +\r
+ response.getStatusLine().getReasonPhrase() + response.getStatusLine()\r
+ .getProtocolVersion());\r
return false;\r
}\r
} finally {\r
httpClient.close();\r
}\r
}\r
+\r
+ private void setHeader(HttpRequestBase httpRequestBase) {\r
+ httpRequestBase.setHeader("Content-Type", "text/html;charset=UTF-8");\r
+ httpRequestBase.setHeader("Accept", "application/json");\r
+ httpRequestBase.setHeader("Content-Type", "application/json");\r
+ }\r
}
\ No newline at end of file