activeMQ指南针_Queue完整分析

?

?

?

ReferenceRecord msg = messageContainer.getValue(entry);testTheNextMsgId(msg.getMessageId().toString());if (msg != null ){...}else{break;}

你这样写我觉得是有问题的;
msg==null情况呢?

我对MQ不是很了解,但我觉得"如果没有可用的话，就放弃本次消息读入",这个内存检测应该在messageContainer.getValue()方法之前或之中要做的吧,如果内存不够返回的msg应该会为null吧?

-关于传输是否连续的问题;

我觉得牵涉到网络传输的东西,作为中间件产品,不保证连续性是否更好?
这个工作给应用来处理是否性能更佳?