qpid

    0熱度

    4回答

    是否有任何選項可以在Apache Qpid的消息級別設置路由密鑰。 我現在的做法是 在地址字符串中指定路由鍵。用這個目的地址創建一個製作人。 topic =(Topic)context.lookup(「destination」); sender = session.createProducer(topic); 通過製作人發送消息。 這樣所有的消息都有相同的路由密鑰。我想實現的是爲每個消息分別設置一

    0熱度

    1回答

    我正在使用qpid消息庫。我有一個持有連接對象的單例類。我注意到我的應用程序將核心退出取決於我如何創建連接。如果我在單例構造函數或靜態方法中創建它,一切都很好,但是如果我使用非靜態方法創建它,或者在我的getinstance方法中創建它,則消息庫在調用析構函數之前會在內部調用close方法它會調用一箇中止。我想知道這些創作電話是不同的,可能會導致這樣的結果。 class Singleton : p

    1熱度

    1回答

    我正在尋找在高消息流量下發出C++ Apache QPID客戶端以獲得最佳性能的最佳方式。 我們的經紀人將包括3個交易所,每個交易所有2個單向隊列。在3「上行鏈路」隊列中將會有大量的流量,這是C++客戶端推動的。 有幾個稀疏記錄的類用於與QPID代理進行接口。連接,會話,發件人和接收者。連接提供會話,會話提供發送者或接收者。在閱讀各種QPID文檔後,我不清楚哪些對象是線程安全的(或者不是線程安全的

    0熱度

    2回答

    我試圖從python的amqp代理接收消息。這裏是我的代碼: #!/usr/bin/python import sys import os import getopt from qpid.messaging import * from qpid.log import enable, DEBUG broker_rcv = "admin/[email protected]:IP" a

    0熱度

    1回答

    Apache qpid沒有直接支持發送日期類型對象。我想發送 datetime從使用Apache Qpid的數據庫和日期對象中獲取,可以跨不同系統移植,即使用C++/Java或任何其他語言使用Apache qpid的系統。 我該如何做到這一點,以便像時區分辨率等所有常見的東西都照顧W/O任何問題。

    1熱度

    1回答

    Apache Qpid Java客戶端API有一個AMQConnection類,用於建立與Qpid消息代理的連接。我正在使用單個字符串構造函數(AMQConnection(String connection))。我有一個實用程序方法,首先創建連接字符串,然後傳遞給AMQConnection構造函數。 連接字符串的格式爲amqp://<username>:<password>@<clientID>/

    0熱度

    1回答

    我堅持試圖編譯qpid C++使用Visual Studio 2010中提升1_47_0。 下面是步驟的順序,我做: 內置升壓1.48.0 新增BOOST_ROOT,BOOST_INCLUDEDIR,BOOST_LIBRARYDIR等方面%PATH%ENV。可變 安裝cmake的,的Python,紅寶石和加入它們的路徑到%PATH%ENV。可變 Untared qpid-CPP-0.14.tar.

    1熱度

    1回答

    我在Eclipse和Tomcat中使用QPid。創建一個動態Web應用程序並設置QPID_HOME,QPID_WORK環境變量。 試行這裏提到的Hello.java例如: - https://svn.apache.org/repos/asf/qpid/trunk/qpid/java/client/example/ 但是在運行這個文件我得到這些錯誤: - Exception in thread "m

    2熱度

    2回答

    如何接收存儲在隊列中的消息數量qpid庫 on python? 我已經試過這樣: from qpid.messaging import * broker_rcv = connect_address address_rcv = queue_name + "; { node: { type: queue }, assert: never , create: never, mode: " + "b

    2熱度

    1回答

    我有一個qpid隊列與該參數: 總線同步隊列--durable --file尺寸= 48 --file計數= 64 欲放入隊列消息。每條消息只是一個字符串,包含個字符。 (002000333222,002000342678等)。我必須設置什麼值來配置--file-size = X --file-count = Y能夠適合所有消息排隊嗎?