美文网首页
common模块阅读3:TopicConfig

common模块阅读3:TopicConfig

作者: 赤子心_d709 | 来源:发表于2017-09-09 14:25 被阅读152次

说明

该类定义类了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
等函数保证读写队列个数

order的顺序是怎么体现的

相关文章

网友评论

      本文标题:common模块阅读3:TopicConfig

      本文链接:https://www.haomeiwen.com/subject/bvnojxtx.html