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 dea1bc3465a3a4aac880de9ac831b1d62f883fcb..af891d03d984f406e44cb65b751c7e42a7f28cc5 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 ba5af9b83f8fd0079f0041fcd2afb4980d0875d1..7636fd5d8a97bf63eee5728a3fbaecc32be05e01 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 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 d802575a6dbd5068f24b22a997e316a73df5c1ef..801cd67eb156a54b67ad584e83d0911d6ae2b38d 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 80742dc06de461591a2650a5c10f94403a6e19d3..e865b6b34a047853dc596f406a5257958ee80177 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 brokerConfigMap = new HashMap(); @@ -25,6 +25,10 @@ public class TopicRemappingDetailWrapper extends RemotingSerializable { private Set brokerToMapOut = new HashSet(); + public TopicRemappingDetailWrapper() { + + } + public TopicRemappingDetailWrapper(String topic, String type, long epoch, Map brokerConfigMap, Set brokerToMapIn, Set brokerToMapOut) { this.topic = topic; this.type = type; @@ -57,4 +61,28 @@ public class TopicRemappingDetailWrapper extends RemotingSerializable { public Set getBrokerToMapOut() { return brokerToMapOut; } + + public void setBrokerConfigMap(Map brokerConfigMap) { + this.brokerConfigMap = brokerConfigMap; + } + + public void setBrokerToMapIn(Set brokerToMapIn) { + this.brokerToMapIn = brokerToMapIn; + } + + public void setBrokerToMapOut(Set 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; + } }