activeMQ罗盘_Queue完整分析
activeMQ指南针_Queue完整分析??? ReferenceRecord msg messageContainer.getValue(entry)testTheNextM
activeMQ指南针_Queue完整分析
?
?
?
ReferenceRecord msg = messageContainer.getValue(entry);testTheNextMsgId(msg.getMessageId().toString());if (msg != null ){...}else{break;}
你这样写我觉得是有问题的;
msg==null情况呢?
我对MQ不是很了解,但我觉得"如果没有可用的话,就放弃本次消息读入",这个内存检测应该在messageContainer.getValue()方法之前或之中要做的吧,如果内存不够返回的msg应该会为null吧?
-关于传输是否连续的问题;
我觉得牵涉到网络传输的东西,作为中间件产品,不保证连续性是否更好?
这个工作给应用来处理是否性能更佳?