2014-02-15 54 views
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(); 

質子非阻塞模式也會發生同樣的情況。

是質子限制還是我做錯了什麼?

+0

首先要做的是對5.10-SNAPSHOT構建進行嘗試,我們一直在努力使AMQP更好地適用於下一個版本。 –

+0

不幸的是,同樣的情況發生在使用最新的5.10-SNAPSHOT(5.10使用質子0.6而不是0.5,但是這不能解決問題) –

回答

0

目前在這方面還沒有Proton或ActiveMQ的已知問題,所以看起來您可能已經發現了一個錯誤。最好的行動方式是用任一項目創建一個Jira問題,以便將其跟蹤。

每當向開源項目報告錯誤時,建議使用單元測試以便開發人員快速查看用例並開始分析它。