qpid

0熱度

1回答

我是Qpid的新手，我試圖設置環境。在讀了大量文檔後，我設法下載了Apache Qpid並讓它在本地主機上運行：8080 我還安裝了maven，cmake。現在我正嘗試在Eclipse中啓動一個新的Maven項目來發送簡單的消息。我不熟悉API接口和概念。我是否需要在我的項目解決方案中包含任何種類的jar或如何使用服務器？我已經找到https://github.com/apache/qpid-

0熱度

2回答

用於加密消息的Qpid和JNDI

我目前正在開發JMS項目，並創建了2個密鑰和2個證書以及我通過Qpid的UI創建的TrustStorage，mytruststore。在我jndi.properties文件我有以下代碼： //Set the InitialContextFactory class to use java.naming.factory.initial = org.apache.qpid.jms.jndi.Jms

0熱度

1回答

Azure Servicebus AMQP URL未被接受/或如何將Liberty連接到Azure服務總線

將Azure ServiceBus通過AMQP通過QPID連接到IBM WAS LibertyProfile時遇到問題。我跟着教程在Microsoft Docs Service Bus Messaging但我得到了以下異常（網址進行模糊處理）： Caused by: Not an AMQP URL amqps://POLICY:[email protected] at org.apache.q

0熱度

1回答

在編譯Docker Alpine中的qpid-cpp時如何解決`構建CXX對象src/CMakeFiles/qpidcommon.dir/qpid/sys/posix/Condition.cpp.o`？

Qpid-CPP已經被編譯在Ubuntu的碼頭工人圖像和當前尺寸是1.86GB： REPOSITORY TAG IMAGE ID CREATED SIZE ubuntu-qpid-cpp latest 7e60a5eabee1 44 hours ago 1.86 GB 目的要編譯搬運工高山內qpid-CPP，以減少的磁盤大小圖像問題一些軟件包在Ubuntu可被省略或不

1熱度

1回答

使用Python Qpid/Proton/Messenger（），如何從Azure事件中心過濾消息？

此要點說明如何使用Messenger（）從Azure事件中心接收消息。它效果很好。 https://gist.github.com/tomconte/e2a4667185a9bf674f59 然而，使用這種技術產生的事件集線器的所有消息。我想閱讀消息，因爲偏移量或時間戳（不關心哪個）。我可以在Qpid文檔中看到如何設置這些要求，但在使用Messenger（）時不會。這裏是在Qpid文檔的相關章節

0熱度

2回答

javax.jms.JMSException：現有連接被遠程主機強制關閉

我是一個試圖整合qpid與Apache Camel的新手。我需要編寫java代碼來使用qpid從隊列讀取和寫入。所以首先我從qpid網站下載了JMS例子。我試圖運行的代碼是。 /* * * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements.

0熱度

1回答

Azure中使用Spring JMS接收相同的消息被接收到多次和信息移動到DLQ

我使用qpid AMQP-1-0-客戶端和相關罐連接到Azure的服務總線建立消費者。我能夠連接到Azure的隊列和接收消息，但問題是我從隊列收到同一消息多次eventhough我處理消息之前承認它。此外，大部分時間我的信息都被轉移到DLQ中。例如，如果我在隊列中有500條消息，則覆蓋MessageListener.onMessage（）的onMessage（）方法將執行超過500次。並將近20

-3熱度

1回答

如何使用java提取對象

我正在將一個xml對象發送給JMS。當檢索我收到一個對象。按照現在這一個XML我發送。但它可以是任何東西，一個XML或一個JSON。有沒有辦法在Java中，我可以提取這個對象並檢索XML/JSON？這是我寫的onMessage（）函數。 public void onMessage(Message message) { Message receivedMessage = message;

0熱度

1回答

連接到耐用消費者 - Qpid質子Python

我試圖讓Qpid Proton Python客戶端通過AMQP v1.0訂閱ActiveMQ代理作爲持久使用者。我可以創建持久訂閱，但不太明白如何在下次運行腳本時獲取相同訂閱。每次運行後，ActiveMQ管理控制檯都會顯示已創建一個持久預訂，並且根據我的腳本輸入命名，但下一次運行只是創建另一個，而不是連接到之前創建的預定。我想我可能會錯過創建「ClientID」（如ActiveMQ所稱的），

0熱度

2回答

SpringBootTest：當啓動應用程序完成

春季啓動集成測試看起來像這樣 @RunWith(SpringRunner.class) @SpringBootTest(classes = Application) class IntegrationTest { static QpidRunner qpidRunner @BeforeClass static void init() { qpidRu