move classparser to rocketmqUtil

apache · Mar 14, 2024 · 31c0117 · 31c0117
1 parent 50d40b5
commit 31c0117
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 15 deletions.
diff --git a/...ard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/TopicProperties.java b/...ard-common/src/main/java/org/apache/eventmesh/dashboard/common/model/TopicProperties.java
@@ -27,7 +27,6 @@
 
 @Data
 public class TopicProperties {
-    private RocketmqProperties rocketmqProperties;
 
     private static final String SEPARATOR = " ";
 

diff --git a/...hboard-common/src/main/java/org/apache/eventmesh/dashboard/common/util/RocketmqUtils.java b/...hboard-common/src/main/java/org/apache/eventmesh/dashboard/common/util/RocketmqUtils.java
@@ -70,18 +70,19 @@ public void createTopic(String topicName, String topicFilterTypeName, int perm,
         }
     }
 
-    public List<TopicConfig> getTopics(String nameServerAddr, long requestTimeoutMillis) {
+    public List<TopicProperties> getTopics(String nameServerAddr, long requestTimeoutMillis) {
         List<TopicConfig> topicConfigList = new ArrayList<>();
         try {
             RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.GET_ALL_TOPIC_CONFIG, (CommandCustomHeader) null);
-            RemotingCommand response = remotingClient.invokeSync(nameServerAddr, request, 3000L);
+            RemotingCommand response = remotingClient.invokeSync(nameServerAddr, request, requestTimeoutMillis);
             TopicConfigSerializeWrapper allTopicConfig = TopicConfigSerializeWrapper.decode(response.getBody(), TopicConfigSerializeWrapper.class);
             ConcurrentMap<String, TopicConfig> topicConfigTable = allTopicConfig.getTopicConfigTable();
             topicConfigList = new ArrayList<>(topicConfigTable.values());
         } catch (Exception e) {
             log.error("RocketmqTopicCheck init failed when examining topic stats.", e);
         }
-        return topicConfigList;
+
+        return topicConfig2TopicProperties(topicConfigList);
     }
 
     public void deleteTopic(String topicName, String nameServerAddr, long requestTimeoutMillis) {
@@ -106,4 +107,5 @@ private List<TopicProperties> topicConfig2TopicProperties(List<TopicConfig> topi
         }
         return topicPropertiesList;
     }
+
 }
diff --git a/...board-core/src/main/java/org/apache/eventmesh/dashboard/core/store/RocketmqTopicCore.java b/...board-core/src/main/java/org/apache/eventmesh/dashboard/core/store/RocketmqTopicCore.java
@@ -23,11 +23,9 @@
 import org.apache.eventmesh.dashboard.common.util.RocketmqUtils;
 import org.apache.eventmesh.dashboard.service.store.TopicCore;
 
-import org.apache.rocketmq.common.TopicConfig;
 import org.apache.rocketmq.common.TopicFilterType;
 import org.apache.rocketmq.common.constant.PermName;
 
-import java.util.ArrayList;
 import java.util.List;
 
 import org.springframework.stereotype.Service;
@@ -46,15 +44,7 @@ public RocketmqTopicCore(RocketmqProperties rocketmqProperties) {
 
     @Override
     public List<TopicProperties> getTopics() {
-        List<TopicConfig> topicConfigList =
-            RocketmqUtils.getTopics(rocketmqProperties.getNamesrvAddr(), rocketmqProperties.getRequestTimeoutMillis());
-        List<TopicProperties> topicPropertiesList = new ArrayList<>();
-        for (TopicConfig topicConfig : topicConfigList) {
-            TopicProperties topicProperties = new TopicProperties();
-            topicProperties.setRocketmqTopicConfig(topicConfig);
-            topicPropertiesList.add(topicProperties);
-        }
-        return topicPropertiesList;
+        return RocketmqUtils.getTopics(rocketmqProperties.getNamesrvAddr(), rocketmqProperties.getRequestTimeoutMillis());
     }
 
     @Override