messagebroker

0熱度

1回答

適用於Java的Qpid經紀人：0.32起開始6.0.4 的Apache HTTP Qpid REST終點時請求使用以下兩種方式發送，即使未響應提供了正確的驗證細節（用戶名「admin」和密碼「admin」）。 HTTP客戶端：RESTClient實現，RestEasy的，HttpRequester（火狐插件）捲曲命令

0熱度

1回答

將MQTT代理用於電子商務移動應用程序

我們已經決定使用MQTT代理（例如emqtt），它使用MQTT協議將移動應用程序連接到業務邏輯服務器。事實上，加載產品，搜索，登錄等所有操作都是通過業務服務器訂閱的渠道完成的。我對這個決定仍然不積極。我們主要選擇MQTT代理，因爲它適用於處理通知。但是，考慮到加載大量數據（例如包含圖片和長文本的產品）也應該通過幫助MQTT代理來完成，我個人認爲也許最好將MQTT代理僅用於通知以及用於其他操作的寧

2熱度

1回答

順序按在ESQL

我有這樣 <Body> <test> <element>2</element> <element>6</element> <element>1</element> </test> </Body> XML消息，我想用最低的數量來選擇元素像這樣 SET data[] = SELECT e FROM Output.Body.test.ele

1熱度

1回答

activemq在代理中向特定用戶發送消息

我使用activemq和spring引導。我想只發送主題給特定的訂閱者。我知道要實現它，我可以在JMSListener上指定選擇器，但這意味着我已經向訂閱者發送了消息。我想要做的是在經紀人級別發送消息。目前，我有下面的代碼： public Broker broker() throws Exception { BrokerService broker = new BrokerServi

0熱度

1回答

同步公共API如何與基於消息的服務集成？

我一直在閱讀有關微服務的信息，並且在JonasBonér的反應性微服務架構中發現了很多有趣的建議（可以免費下載here）。他強調需要在miroservices之間進行異步通信，但他表示外部客戶端的API有時需要同步（通常是REST）。我一直在想如何從微服務發回的異步響應消息應該最好路由回等待的客戶端。對我來說，最明顯的方法是在處理請求時發送的所有消息中記錄請求標識，然後將此標識複製到服務發送的響

6熱度

1回答

如何讓我的ActiveMQ代理放置離線持久訂閱者

我們有一個ActiveMQ代理，它使用JMS，AMQP和MQTT連接到來自不同客戶端的代理。出於某種原因，我們還沒有弄清楚一組特定的MQTT客戶端經常（並非總是）持久訂閱。這是一個測試環境，客戶端經常被添加和刪除，後者有時通過拔插或重新啓動嵌入式設備，以便他們不能正確取消訂閱。效果（IIUC）是，代理爲可能永遠不會再看到的設備（我可以在http://my_broker:8161/admin/sub

1熱度

1回答

Apache Kafka和Strom Clojure的實現

這是第一次實現流處理基礎設施，我的毒性是storm 1.0.1, kafka 0.9.0和Clojure 1.5。現在我有一個使用郵件系統（RabbitMQ）的背景，我喜歡它有幾個原因。易於安裝和維護尼斯前端Web門戶持久消息狀態被保持在那裏我可以開始一個消費者，它知道哪個消息沒有被消耗掉。即「恰好一次」然而它不能達到我想要的吞吐量。現在已經走過卡夫卡它很大程度上依賴於手動保持偏移（內

0熱度

1回答

如何從Java返回MbElement []到ESQL？

我想將REFERENCE作爲參數傳遞給Java方法並進行轉換，然後我想以MbElement []的形式返回。直到現在我試了下面。我使用以下代碼中ESQL CALL retrieveData(CAST(AGE AS INTEGER),OutputRoot.XMLNSC.employees) into RESULT; 調用Java方法如下： create function retrieveDa

0熱度

1回答

IBM Integration Bus Java計算節點：輸出w3c.dom.Document或字符串

過去幾個月來，我一直在研究Java模塊以轉換XML。例如，它應該接受一個soap請求並使用元數據存儲庫中的其他元素填充soap：header元素。該模塊應該普遍適用於任何中間件（我的本機系統是SAP PI）。現在我的任務是將此模塊作爲jar實現到IBM Integration Bus中的JavaCompute節點中。問題是導出生成的XML我需要將數據導入JavaCompute節點的outMess

0熱度

1回答

到WSO2 Message Broker的管理連接

我從這個頁面嘗試樣本代碼來測試發佈消息到WSO2 Message Broker的： https://docs.wso2.com/display/MB310/Sending+and+Receiving+Messages+Using+Queues 的示例代碼出現連接 - >發佈 - >斷開。我認爲這不是生產代碼的典型設計。我試圖減少被調用每一次我發佈一條消息（幾次秒）時間的代碼，但它看起來像連接斷開