[ISSUE #212]For multiple listening instances, only the last started i…

…nstance can receive messages
apache · Feb 7, 2021 · 1ffdebe · 1ffdebe
1 parent 481cf7d
commit 1ffdebe
Showing 1 changed file with 16 additions and 12 deletions.
diff --git a/...in/java/com/webank/eventmesh/runtime/core/protocol/http/processor/HeartBeatProcessor.java b/...in/java/com/webank/eventmesh/runtime/core/protocol/http/processor/HeartBeatProcessor.java
@@ -150,18 +150,7 @@ public void processRequest(ChannelHandlerContext ctx, AsyncContext<HttpCommand>
                     proxyHTTPServer.localClientInfoMapping.put(groupTopicClientMapping.getKey(), groupTopicClientMapping.getValue());
                 }else {
                     List<Client> tmpClientList = groupTopicClientMapping.getValue();
-                    for (Client tmpClient : tmpClientList){
-                        boolean isContains = false;
-                        for (Client localClient : localClientList){
-                            if (StringUtils.equals(localClient.url, tmpClient.url)){
-                                isContains = true;
-                                break;
-                            }
-                        }
-                        if (!isContains){
-                            localClientList.add(tmpClient);
-                        }
-                    }
+                    supplyClientInfoList(tmpClientList, localClientList);
                     proxyHTTPServer.localClientInfoMapping.put(groupTopicClientMapping.getKey(), localClientList);
                 }
 
@@ -203,6 +192,21 @@ public void onResponse(HttpCommand httpCommand) {
 
     }
 
+    private void supplyClientInfoList(List<Client> tmpClientList, List<Client> localClientList) {
+        for (Client tmpClient : tmpClientList){
+            boolean isContains = false;
+            for (Client localClient : localClientList){
+                if (StringUtils.equals(localClient.url, tmpClient.url)){
+                    isContains = true;
+                    break;
+                }
+            }
+            if (!isContains){
+                localClientList.add(tmpClient);
+            }
+        }
+    }
+
     @Override
     public boolean rejectRequest() {
         return false;