小编Bre*_*man的帖子

我一直在评估ActiveMQ作为候选消息代理.我编写了一些测试代码,试图了解ActiveMQ的性能限制.

我可以通过尽快发送消息来在代理中生成故障状态,如下所示:

try {
    while(true) {
        byte[] payload = new byte[(int) (Math.random() * 16384)];
        BytesMessage message = session.createBytesMessage();
        message.writeBytes(payload);
        producer.send(message);
} catch (JMSException ex) { ... }

我很惊讶这条线

producer.send(message);

当经纪人进入失败状态时阻止.我希望会抛出一些异常,因此会有一些迹象表明经纪人已经失败了.

我意识到我的测试代码是在向代理发送垃圾邮件,我希望代理失败.但是,我更希望经纪人"大声"失败而不是简单地阻止.

这是不切实际的期望吗？

更新:

Uri的回答引用了3月提交的ActiveMQ错误报告.错误描述包括一个听起来像我正在寻找的提案:"如果传输上的请求超时(这是为了捕获故障情况,那么预计不会合理发生的事情),事情就会产生错误而不是建立等待线程."

但是,在8个月之后,该错误目前未通过一次投票分配.所以我想这个问题仍然存在,这是ActiveMQ应该(将会)实现的吗？