1
我正在使用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();
質子非阻塞模式也會發生同樣的情況。
是質子限制還是我做錯了什麼?
首先要做的是對5.10-SNAPSHOT構建進行嘗試,我們一直在努力使AMQP更好地適用於下一個版本。 –
不幸的是,同樣的情況發生在使用最新的5.10-SNAPSHOT(5.10使用質子0.6而不是0.5,但是這不能解決問題) –