[rocketmq] branch 5.0.0-alpha-static-topic updated: Fix serialize problem

[do...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dongeforever pushed a commit to branch 5.0.0-alpha-static-topic
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/5.0.0-alpha-static-topic by this push:
     new 8962581  Fix serialize problem
8962581 is described below

commit 8962581ec2d756dcb4d64db5cecc421488e3da9f
Author: dongeforever <do...@apache.org>
AuthorDate: Wed Nov 24 15:44:32 2021 +0800

    Fix serialize problem
---
 .../statictopic/TopicConfigAndQueueMapping.java    |  4 +++
 .../common/statictopic/TopicQueueMappingInfo.java  |  2 ++
 .../common/statictopic/TopicQueueMappingOne.java   |  1 -
 .../statictopic/TopicRemappingDetailWrapper.java   | 34 ++++++++++++++++++++--
 4 files changed, 37 insertions(+), 4 deletions(-)

diff --git a/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicConfigAndQueueMapping.java b/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicConfigAndQueueMapping.java
index dea1bc3..af891d0 100644
--- a/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicConfigAndQueueMapping.java
+++ b/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicConfigAndQueueMapping.java
@@ -32,4 +32,8 @@ public class TopicConfigAndQueueMapping extends TopicConfig {
     public TopicQueueMappingDetail getMappingDetail() {
         return mappingDetail;
     }
+
+    public void setMappingDetail(TopicQueueMappingDetail mappingDetail) {
+        this.mappingDetail = mappingDetail;
+    }
 }
diff --git a/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingInfo.java b/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingInfo.java
index ba5af9b..7636fd5 100644
--- a/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingInfo.java
+++ b/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingInfo.java
@@ -92,4 +92,6 @@ public class TopicQueueMappingInfo extends RemotingSerializable {
     public void setCurrIdMap(ConcurrentMap<Integer, Integer> currIdMap) {
         this.currIdMap = currIdMap;
     }
+
+
 }
diff --git a/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingOne.java b/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingOne.java
index d802575..801cd67 100644
--- a/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingOne.java
+++ b/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingOne.java
@@ -16,7 +16,6 @@
  */
 package org.apache.rocketmq.common.statictopic;
 
-import com.google.common.collect.ImmutableList;
 import org.apache.rocketmq.remoting.protocol.RemotingSerializable;
 
 import java.util.List;
diff --git a/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicRemappingDetailWrapper.java b/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicRemappingDetailWrapper.java
index 80742dc..e865b6b 100644
--- a/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicRemappingDetailWrapper.java
+++ b/common/src/main/java/org/apache/rocketmq/common/statictopic/TopicRemappingDetailWrapper.java
@@ -15,9 +15,9 @@ public class TopicRemappingDetailWrapper extends RemotingSerializable {
     public static final String SUFFIX_AFTER = ".after";
 
 
-    private final String topic;
-    private final String type;
-    private final long epoch;
+    private String topic;
+    private String type;
+    private long epoch;
 
     private Map<String, TopicConfigAndQueueMapping> brokerConfigMap = new HashMap<String, TopicConfigAndQueueMapping>();
 
@@ -25,6 +25,10 @@ public class TopicRemappingDetailWrapper extends RemotingSerializable {
 
     private Set<String> brokerToMapOut = new HashSet<String>();
 
+    public TopicRemappingDetailWrapper() {
+
+    }
+
     public TopicRemappingDetailWrapper(String topic, String type, long epoch, Map<String, TopicConfigAndQueueMapping> brokerConfigMap, Set<String> brokerToMapIn, Set<String> brokerToMapOut) {
         this.topic = topic;
         this.type = type;
@@ -57,4 +61,28 @@ public class TopicRemappingDetailWrapper extends RemotingSerializable {
     public Set<String> getBrokerToMapOut() {
         return brokerToMapOut;
     }
+
+    public void setBrokerConfigMap(Map<String, TopicConfigAndQueueMapping> brokerConfigMap) {
+        this.brokerConfigMap = brokerConfigMap;
+    }
+
+    public void setBrokerToMapIn(Set<String> brokerToMapIn) {
+        this.brokerToMapIn = brokerToMapIn;
+    }
+
+    public void setBrokerToMapOut(Set<String> brokerToMapOut) {
+        this.brokerToMapOut = brokerToMapOut;
+    }
+
+    public void setTopic(String topic) {
+        this.topic = topic;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    public void setEpoch(long epoch) {
+        this.epoch = epoch;
+    }
 }