qpid

22熱度

4回答

我瀏覽了一個開源的通訊軟件和之後的研究提供一些好一點，我碰到這三種產品。我已經拿出了這些初步測試的驅動器，讓他們處理隊列和主題的消息，並且從我讀過的所有這三個產品都可以很好地爲大多數公司提供開源消息傳遞解決方案。我想知道的是，這些產品相對於另一個產品而言有什麼優勢？我特別感興趣的是消息吞吐量，包括持久消息吞吐量，安全性，可擴展性，可靠性，支持，路由功能，管理選項（如度量和監控），以及每個程序在大型

0熱度

1回答

Qpid ObjectMessage破壞問題

我對我的問題有一個簡單的POC。我有一個生產者和一個消費者來讀寫ObjectMessage到Qpid隊列。 Dummy對象所有的是一個String。 Dummy對象也是可序列化的。生產者似乎在沒有拋出錯誤的情況下將對象寫入隊列，但正在偵聽隊列的消費者無法對Dummy對象進行反序列化。 OnMessage（接收消息時），簡單虛擬dummyObj =（虛擬）（（JMSObjectMessage）ar

2熱度

1回答

使用高級API的QPID更精細的AMQP控制？

起初我認爲QPID文檔很棒，但現在我覺得很困惑。我正在使用QPID-0.6的C++ API和qpid :: messaging命名空間（我看到我可以使用qpid :: client的低級別AMQP，但它不是我現在所希望的）。使用AMQP，我會在發送消息之前聲明與類型的交換，聲明隊列和綁定。使用QPID，我可以給發件人發送一個地址。是否有任何地址示例的文檔，它們是否也一樣？（創建各種交換，隊列和

0熱度

2回答

負載平衡

最近，我開始需要實現信息和可行的選擇是項目工作：Apache的Qpid或RabbitMQ的，我的任務是這樣的：。 + A + >> [百萬的設備（生產者） - 連接到 - 消息服務器（羣集 - Qpid或RabbitMQ的）] {LOAD 然後 + B + >> BALANCING） [Messaging Server（羣集 - Qpid或RabbitMQ） - 連接到 - Gate路服務器（集

1熱度

4回答

QPid的Maven倉庫

我正在嘗試使用QPid作爲JMS提供程序。 Maven被用作構建工具。我找不到包含QPid的maven倉庫，所以我的構建失敗。問題是否有人知道包含qpid MVN庫？是否有解決方法？我已經下載了所有的JAR文件，並試圖將它們放在.m2/repository/org/apache/qpid/qpid-common/0.6中和 .m2/repository/org/apache/qpid/qp

1熱度

2回答

如何使用amq.topic在阿帕奇的pub/sub消息Qpid

我有一個C++出版商發送消息是這樣的： Connection connection; connection.open("127.0.0.1", 5672); Session session = connection.createSession(); Message msg; msg.setData("TestAMsg"); msg.getDeliveryProperties().setR

2熱度

1回答

Qpid - 負載均衡的消息對消費者有不同的性能特點

我有以下情形：我推100個消息2名消費者共享的隊列。兩個訂閱者都以預獲取模式和顯式模式訂閱隊列。在處理每條消息之後，每個訂閱者接受消息以將其從隊列中刪除。僞代碼看喜歡的是： OnMessageTransfer(message) : DoSomethingWithMessage(message) Session.MessageAccept(message) 的消息是正確的負

0熱度

1回答

忽略Qpid/AMQP中的環回消息？

有沒有辦法忽略來自Qpid/AMQP的消息？我已經在qpid的文檔和源代碼中找到了解決方法，並且找不到可以忽略它們的標誌。這似乎是將傳遞給exchangeBind（）的東西。

3熱度

1回答

網絡級高速緩存

我們正在構建一個測試客戶機，爲Apache Qpid做一些加載/故障轉移測試。我的管理員同行告訴我應該隨機化消息有效負載中的字節。他們對此的推理是存在某種類型的緩存可能會影響測試的有效性。在我將所有有效載荷字節（它本身會對測試結果產生影響）隨機化的麻煩之前，這是真的嗎？是否有緩存將發生在我應該知道的界面級別？你認爲這可能會顯着影響我的測試結果嗎？考慮到除了消息的有效載荷以外，其他字段將會改變（

0熱度

1回答

Apache qpid setDelay

Apache qpid-cpp messaging api是否支持在ActiveMQ中延遲傳遞消息？ TextMessage message = session.createTextMessage("test msg"); long time = 60 * 1000; message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_