activeMQ笑颜计划_durableTopic的Nolocal的bug分析
因群里的网友发现DurableTopicSubscription的NoLocal问题,具体问题描述请参考https://issues.apache.org/activemq/browse/AMQ-2561。基于我现在时间的原因,我把问题原因和解决方案做一简单方法,希望对碰到同样问题的朋友有所帮助。
原因分析:
activeMQ处理DurableTopicSubscription的过程大致如下:
问题就在当某个DurableTopicSubscription第一次是正常的,但之后再重新启动时,activeMQ找到对应的subscription并激活它,但是忘了刷新它的selectorExpression,这就导致网友提出的那个bug。
解决方法:
1.修改AbstractSubscription类的private static BooleanExpression parseSelector(ConsumerInfo info) throws InvalidSelectorException方法为protected或public
2.AbstractSubscription类新增一个方法public void setSelectorExpression(BooleanExpression selectorExpression)
{
this.selectorExpression = selectorExpression;
}
3.修改DurableTopicSubscription类的public void activate(SystemUsage memoryManager, ConnectionContext context, ConsumerInfo info) throws Exception方法,
新增一行setSelectorExpression(parseSelector(info));
很久没写文章了,希望对大家能有所帮助,欢迎更多的人参与activeMQ的使用和源码分析中来,毕竟activeMQ是值得我们研究的。