common模块阅读3:TopicConfig
2017-09-09 本文已影响152人
赤子心_d709
说明
该类定义类了topic的配置项
字段
private static final String SEPARATOR = " ";
public static int defaultReadQueueNums = 16;//默认读队列个数
public static int defaultWriteQueueNums = 16;//默认写队列个数
private String topicName;//主题name
private int readQueueNums = defaultReadQueueNums;//读队列个数
private int writeQueueNums = defaultWriteQueueNums;//写队列个数
private int perm = PermName.PERM_READ | PermName.PERM_WRITE;//权限
private TopicFilterType topicFilterType = TopicFilterType.SINGLE_TAG;
private int topicSysFlag = 0;// 系统属性， 见TopicSysFlag类
private boolean order = false;// 是否顺序
方法
都是get,set,Object相关的方法，不介绍了
问题
读写队列个数限制，在哪里体现的
感觉是
RouteInfoManager#createAndUpdateQueueData传递给QueueData
然后
MQClientInstance#topicRouteData2TopicPublishInfo
MQClientInstance#topicRouteData2TopicSubscribeInfo
等函数保证读写队列个数
