java - AMQP Qpid Proton - 无法将消息发送到超过 256 个队列

Question

我使用 AMQP 1.0 和 Qpid Proton 0.6 以及 ActiveMQ 5.9.0 作为代理。

当向少于 256 个队列发送消息时，一切正常。

当在 256 个队列之后向超过 256 个 Proton 区 block 发送消息时。

Messenger mng = new MessengerImpl();
mng.start();

for (int i = 0; i < 300; i++) {
    Message message = new MessageImpl();
    String address = "amqp://localhost:5672/queue://receiver";
    message.setAddress(address+i);
    message.setBody(new AmqpValue("test message"));                   
    mng.put(message);
}        

mng.send();
mng.stop();

同样的情况也会发生在 Proton 非阻塞模式上。

这是 Proton 的限制还是我做错了什么？

Answer 1

目前 Proton 或 ActiveMQ 在这方面没有已知问题，因此您可能发现了一个错误。最好的做法是为任一项目创建一个 Jira 问题，以便对其进行追踪。

每当向开源项目报告错误时，最好包含单元测试，以便开发人员可以快速查看用例并开始分析它。