AMQP Qpid质子 - 无法发送消息到超过256个队列

我正在使用AMQP 1.0与Qpid质子0.6和ActiveMQ 5.9.0作为代理。AMQP Qpid质子 - 无法发送消息到超过256个队列

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

在256队列后发送消息到超过256个质子块时。

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();

质子非阻塞模式也会发生同样的情况。

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

来源

2014-02-15 salata.mar

首先要做的是对5.10-SNAPSHOT构建进行尝试，我们一直在努力使AMQP更好地适用于下一个版本。 –

不幸的是，同样的情况发生在使用最新的5.10-SNAPSHOT（5.10使用质子0.6而不是0.5，但是这不能解决问题） –

目前在这方面还没有Proton或ActiveMQ的已知问题，所以看起来您可能已经发现了一个错误。最好的行动方式是用任一项目创建一个Jira问题，以便将其跟踪。

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

来源

2014-02-18 14:35:26

AMQP Qpid质子 - 无法发送消息到超过256个队列

回答

相关问题