qpid

1熱度

1回答

我正在使用AMQP 1.0與Qpid質子0.6和ActiveMQ 5.9.0作爲代理。將消息發送到少於256個隊列時，一切正常。在256隊列後發送消息到超過256個質子塊時。 Messenger mng = new MessengerImpl(); mng.start(); for (int i = 0; i < 300; i++) { Message message = ne

1熱度

1回答

AMQP上的ServiceBus關閉消費者

我們已經預先安裝了ServiceBus和Java JMS QPID客戶端0.26。看起來SB中存在bug - 當生產者關閉連接時，它向消費者發送END命令。生產者和消費者都必須在同一臺機器上運行。首先開始消費該隊列上偵聽： static void consumeFromQueueForStackOverflow(Connection connection, Context context)

2熱度

1回答

設置在使用Python綁定

我試圖發送郵件使用Python的Qpid質子結合自定義屬性，但是我無法找到這樣做的正確方法Qpid騰自定義郵件屬性... message = Message() message.body = u"hello body" data = Data() data.put_map() data.enter() data.put_string("key")

0熱度

3回答

AMQP - 用於Node.js的Apache Qpid客戶端

我一直在嘗試爲Node.js找到Apache Qpid客戶端。我找到了這個node-qpid軟件包，但它太舊了，即使使用README中提到的qpid-proton-C 0.3也沒有安裝。我只是基本上想要一個Node.js的AMQP客戶端，它可以成功地與QPID C++ Broker交談。大多數AMQP客戶端像這樣（amqplib）（AMQP 0-9-1）我找到的Node.js不能與QPID

0熱度

1回答

AMQP使用Elixir將連接字符串連接到Active MQ

我使用ActiveMQ作爲消息代理，並使用Qpid proton c庫連接到Erlang進行消息傳遞服務，並且在運行ActiveMQ的情況下似乎可以很好地處理以下命令。 qpidpn:subscribe("amqp://127.0.0.1/topic://destination"). qpidpn:publish(#{address => "amqp://127.0.0.1/topic://de

2熱度

1回答

LNK1104：無法打開文件 'boost_thread-VC100-MT-GD-1_55.lib'

我現在面臨的困難在Windows XP上建立qpid CPP解決方案我已經安裝了升壓1.55.0，Python 2.7版，紅寶石2.0.0和2.8的CMake 然後我已經加入環境變量Python，Ruby和CMake的路徑，然後升壓變量是組作爲隨後 BOOST_ROOT C：\升壓 BOOST_LIB RARYDIR C：\升壓\ lib中 BOOST_INCLUDEDIR C：\升壓\包括

0熱度

1回答

瀏覽服務總線隊列掛在hasMoreElements（）

我們有內部服務總線安裝。我可以使用QPID AMQP 1.0 0.24客戶端發佈和訂閱/讀取消息。然而，如果隊列瀏覽不起作用，那麼當hasMoreElements（）隊列中沒有更多消息時，調用會無限期地掛起。堆棧跟蹤是： Thread [main] (Suspended) waiting for: ConnectionEndpoint (id=19) Object.wait(long) li

0熱度

1回答

有沒有辦法將qpid綁定到除localhost以外的其他IP？

我只是好奇，如果有一種方法來綁定qpid到IP如127.1.244.129 我問的原因是我正在尋找部署許多實例到PaaS，並將需要多個運行實例。這是不可能的，如果一切都試圖綁定到本地主機：8080。有沒有人知道一個方法o配置這個？我無法在qpid文檔中找到。

0熱度

2回答

通過AMQP的ServiceBus丟失重新發送的消息

我們有ServiceBus的內部部署安裝。處理重新交付時我注意到了奇怪的行爲。我創建了示例應用程序，請參閱下圖。這個應用程序將發佈5個消息給持久隊列的主題，並試圖讀取所有消息。對於每條消息，它將創建新會話和開始/停止消息傳遞（超時是啓動/停止qpid後臺線程所需的時間）。我想預取將使注意讀取消息偷看鎖定。我希望最終得到所有消息，但有些消息正在丟失。最大交付計數設置爲10.該隊列由Serviuce總

1熱度

1回答

Qpid與Java的異步消息傳遞

我是Qpid和JMS的新手，我正在嘗試使用Qpid Java代理創建一個非常簡單的Java應用程序。我正在實現這個簡單地發送和接收預定義消息的例子。 http://qpid.apache.org/releases/qpid-0.24/qpid-jms/examples/Hello.java.html 我在2份，消費者和生產者劃分該應用程序。如果我先啓動示例的消費者部分，然後啓動生產者部分，那麼