提交 8962581e 编写于 作者: D dongeforever

Fix serialize problem

上级 a8ef92e9
...@@ -32,4 +32,8 @@ public class TopicConfigAndQueueMapping extends TopicConfig { ...@@ -32,4 +32,8 @@ public class TopicConfigAndQueueMapping extends TopicConfig {
public TopicQueueMappingDetail getMappingDetail() { public TopicQueueMappingDetail getMappingDetail() {
return mappingDetail; return mappingDetail;
} }
public void setMappingDetail(TopicQueueMappingDetail mappingDetail) {
this.mappingDetail = mappingDetail;
}
} }
...@@ -92,4 +92,6 @@ public class TopicQueueMappingInfo extends RemotingSerializable { ...@@ -92,4 +92,6 @@ public class TopicQueueMappingInfo extends RemotingSerializable {
public void setCurrIdMap(ConcurrentMap<Integer, Integer> currIdMap) { public void setCurrIdMap(ConcurrentMap<Integer, Integer> currIdMap) {
this.currIdMap = currIdMap; this.currIdMap = currIdMap;
} }
} }
...@@ -16,7 +16,6 @@ ...@@ -16,7 +16,6 @@
*/ */
package org.apache.rocketmq.common.statictopic; package org.apache.rocketmq.common.statictopic;
import com.google.common.collect.ImmutableList;
import org.apache.rocketmq.remoting.protocol.RemotingSerializable; import org.apache.rocketmq.remoting.protocol.RemotingSerializable;
import java.util.List; import java.util.List;
......
...@@ -15,9 +15,9 @@ public class TopicRemappingDetailWrapper extends RemotingSerializable { ...@@ -15,9 +15,9 @@ public class TopicRemappingDetailWrapper extends RemotingSerializable {
public static final String SUFFIX_AFTER = ".after"; public static final String SUFFIX_AFTER = ".after";
private final String topic; private String topic;
private final String type; private String type;
private final long epoch; private long epoch;
private Map<String, TopicConfigAndQueueMapping> brokerConfigMap = new HashMap<String, TopicConfigAndQueueMapping>(); private Map<String, TopicConfigAndQueueMapping> brokerConfigMap = new HashMap<String, TopicConfigAndQueueMapping>();
...@@ -25,6 +25,10 @@ public class TopicRemappingDetailWrapper extends RemotingSerializable { ...@@ -25,6 +25,10 @@ public class TopicRemappingDetailWrapper extends RemotingSerializable {
private Set<String> brokerToMapOut = new HashSet<String>(); 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) { public TopicRemappingDetailWrapper(String topic, String type, long epoch, Map<String, TopicConfigAndQueueMapping> brokerConfigMap, Set<String> brokerToMapIn, Set<String> brokerToMapOut) {
this.topic = topic; this.topic = topic;
this.type = type; this.type = type;
...@@ -57,4 +61,28 @@ public class TopicRemappingDetailWrapper extends RemotingSerializable { ...@@ -57,4 +61,28 @@ public class TopicRemappingDetailWrapper extends RemotingSerializable {
public Set<String> getBrokerToMapOut() { public Set<String> getBrokerToMapOut() {
return brokerToMapOut; 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;
}
} }
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册