X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=holmes-actions%2Fsrc%2Fmain%2Fjava%2Forg%2Fopeno%2Fholmes%2Fcommon%2Futils%2FMSBRegisterUtil.java;h=f7825e7a5fc81d761679bd36602c7fbf4b52ee20;hb=68d0b52af532f4cde355b642593e76cf737aeb21;hp=fc5e88213948a4bacc5566bcffff075bc91ff606;hpb=9a197a9d3edf2d0ef24a3b2f417e918cff07dab5;p=holmes%2Fcommon.git

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..f7825e7 100644
--- 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
@@ -16,51 +16,58 @@
 
 package org.openo.holmes.common.utils;
 
-import com.fasterxml.jackson.databind.ObjectMapper;
+import com.eclipsesource.jaxrs.consumer.ConsumerFactory;
 import java.io.IOException;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.StringUtils;
-import org.apache.http.HttpResponse;
-import org.apache.http.client.methods.HttpPost;
-import org.apache.http.entity.ByteArrayEntity;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClients;
 import org.jvnet.hk2.annotations.Service;
 import org.openo.holmes.common.api.entity.ServiceRegisterEntity;
 import org.openo.holmes.common.config.MicroServiceConfig;
-import org.openo.holmes.common.constant.AlarmConst;
+import org.openo.holmes.common.msb.MicroserviceBusRest;
 
 @Slf4j
 @Service
 public class MSBRegisterUtil {
 
-    public boolean register(ServiceRegisterEntity entity) throws IOException {
-        CloseableHttpClient httpClient = HttpClients.createDefault();
-        try {
-            ObjectMapper mapper = new ObjectMapper();
-            String content = mapper.writeValueAsString(entity);
-            HttpPost httpPost = new HttpPost("http://" + MicroServiceConfig.getMsbServerAddr()
-                    + ":8086/api/microservices/v1/services?createOrUpdate=false");
-            if (StringUtils.isNotEmpty(content)) {
-                httpPost.setEntity(new ByteArrayEntity(content.getBytes()));
-            }
-            HttpResponse response;
-            try {
-                response = httpClient.execute(httpPost);
-            } catch (Exception e) {
-                log.warn("Registering the service to the bus failure", e);
-                return false;
-            }
-            if (response.getStatusLine().getStatusCode() == AlarmConst.RESPONSE_STATUS_OK) {
-                log.info("Registration successful service to the bus :" + response.getEntity());
-                return true;
+    public void register(ServiceRegisterEntity entity) throws IOException {
+        log.info("start holmes micro service register");
+        boolean flag = false;
+        int retry = 0;
+        while (!flag && retry < 20) {
+            log.info("Holmes microservice register. retry:" + retry);
+            retry++;
+            flag = innerRegister(entity);
+            if (!flag) {
+                log.warn("micro service register failed, sleep 30S and try again.");
+                threadSleep(30000);
             } else {
-                log.warn("Registering the service to the bus failure:"+response.getStatusLine().getStatusCode()+" "+
-                response.getStatusLine().getReasonPhrase()+response.getStatusLine().getProtocolVersion());
-                return false;
+                log.info("micro service register success!");
+                break;
             }
-        } finally {
-            httpClient.close();
         }
+        log.info("holmes micro service register end.");
+    }
+
+    private boolean innerRegister(ServiceRegisterEntity entity) {
+        try {
+            log.info("msbServerAddr:" + MicroServiceConfig.getMsbServerAddr());
+            log.info("entity:" + entity);
+            MicroserviceBusRest resourceserviceproxy = ConsumerFactory.createConsumer(
+                    MicroServiceConfig.getMsbServerAddr(), MicroserviceBusRest.class);
+            resourceserviceproxy.registerServce("false", entity);
+        } catch (Exception error) {
+            log.error("microservice register failed!" + error.getMessage(), error);
+            return false;
+        }
+        return true;
+    }
+
+    private void threadSleep(int second) {
+        log.info("start sleep ....");
+        try {
+            Thread.sleep(second);
+        } catch (InterruptedException error) {
+            log.error("thread sleep error.errorMsg:" + error.getMessage(), error);
+        }
+        log.info("sleep end .");
     }
 }
\ No newline at end of file