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

Question

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

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

在 256 个队列后向超过 256 个 Proton 块发送消息时。

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 非阻塞模式也会出现同样的情况。

是质子限制还是我做错了什么？

Answer 1

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

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