Fix register micro service code

[holmes/common.git] / holmes-actions / src / main / java / org / openo / holmes / common / utils / MSBRegisterUtil.java

diff --git a/holmes-actions/src/main/java/org/openo/holmes/common/utils/MSBRegisterUtil.java b/holmes-actions/src/main/java/org/openo/holmes/common/utils/MSBRegisterUtil.java
index fc5e882..30e411f 100644 (file)
--- a/holmes-actions/src/main/java/org/openo/holmes/common/utils/MSBRegisterUtil.java
+++ b/holmes-actions/src/main/java/org/openo/holmes/common/utils/MSBRegisterUtil.java
@@ -22,6 +22,7 @@ import lombok.extern.slf4j.Slf4j;
 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
@@ -44,6 +45,7 @@ public class MSBRegisterUtil {
             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
@@ -55,12 +57,20 @@ public class MSBRegisterUtil {
                 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