【发布时间】:2014-03-15 03:52:11
【问题描述】:
我使用 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 非阻塞模式。
是 Proton 限制还是我做错了什么?
【问题讨论】:
-
首先要做的是针对 5.10-SNAPSHOT 构建进行尝试,我们一直在努力使 AMQP 在下一个版本中变得更好。
-
不幸的是,使用最新的 5.10-SNAPSHOT 也会发生同样的情况(5.10 使用的是质子 0.6 而不是 0.5,但这并不能解决问题)