messagebroker

    1熱度

    1回答

    我需要接收隊列的消息,但該隊列是在另一臺機器(AWS實例)內以https(https://www.mymachine.com/rabbitmq),但是當我要建立隊列,我得到一個連接一個NullPointerException。 這是代碼的一部分: factory.setHost(https://www.mymachine.com/rabbitmq); Connection connection

    0熱度

    1回答

    我試圖把MQMD.MsgId到XMLNSC.MsgId領域,像這樣: SET OutputRoot.XMLNSC.Root.MsgId = InputRoot.MQMD.MsgId; 但是我卻越來越X'414d51204d39392e5352442e4330302e56c47bd4203b3708',而不是僅僅414d51204d39392e5352442e4330302e56c47bd4203b

    1熱度

    1回答

    我一直在關注Using WSO2 MB as A JMS Broker for WSO2 CEP Server的sample官方WSO2 MB文檔。由於此文檔不支持最新版本的CEP,因此嘗試將MB與CEP 3.1.0相集成。 根據給定的步驟,據我所知,一旦CEP和MB啓動,應該自動生成「org.wso2.sample.stock.quote.basic:1.0.0」流並顯示在事件流部分並跑步。我是

    0熱度

    1回答

    我正在使用IIB 9.0.0.2,其中我創建了一個連接到SQL Server數據庫(版本2012)的消息流以在表中插入記錄。該代碼被編寫爲每1分鐘與數據庫進行交互。 當數據庫出現故障時,代理會拋出下面的錯誤(與預期的一樣),但是當數據庫啓動時,它仍會拋出相同的錯誤,而不是連接回去,直到我重新啓動流程。 根SQL異常-1 /opt/ibm/IE02/2.0.1/lib/libodbcinterfac

    1熱度

    1回答

    我一直在使用Apache Kafka加WSO2 Message Broker以便發佈和使用消息使用Topics。但除了更改WSO2 MB中的jndi屬性外,集成WSO2 CEP的配置在兩者中看起來都是相同的。 我相信它有它自己的專業'&缺'。我已經通過了卡夫卡的doc和WSO2 MB文檔。比較一個和另一個時有什麼重大區別?任何幫助,將不勝感激。

    0熱度

    1回答

    我一直在使用WSO2 Message Broker以便通過jms和其他客戶端發佈和使用消息。我已經通過官方documentation包括樣品。 我想知道的是,WSO2 MB可以直接處理http請求,而不是jms。是的,您可以通過將http轉換爲jms來執行類似this的操作,這似乎是一個漫長的過程。 ie:我的意思是使用http作爲終點,或者在WSO2 Message Broker中直接發佈和使用

    0熱度

    1回答

    如何才能在WSO2 Message Broker中執行Performance Tuning?我確實通過this文檔解釋瞭如何修改broker.xml中的參數值,理想的確改善了消息傳遞和消費的性能。 這些都是我改的參數: ringBufferSize windowSize contentReadBatchSize BUFFERSIZE 還有什麼,我應該爲了提高改變優化?我想知道的是,除perform

    0熱度

    1回答

    我想知道,在.NET平臺中我們有像JMS這樣的消息傳遞系統嗎? 我看到類似的RabbitMQ但服務器在二郎山寫的,我希望有一個.NET服務器 任何人都可以指導我怎麼可以編寫一個基於AMQP協議的服務器? 任何人都可以指導我在C#中實現AMQP 1.0協議的庫嗎? 我想起初我必須在.NET中使用amqp協議 請幫幫我。

    2熱度

    1回答

    我目前正在使用IBM Integration Bus v9,並試圖從聚合消息中獲取DOM節點(org.w3c.dom.Node)以將其解組爲Java對象。 在我的流程的第一個版本,我是同步調用只有一個Web服務,而且從Java Compute節點,我是直接從MbMessage得到DOM文檔,並解組通過以下方式(source): MbMessage inMessage = inAssembly.ge

    0熱度

    1回答

    我正在使用WSO2 ESB 4.9與Message Broker一起保證傳遞消息。 我的消息處理器向代理服務發送一條消息,在該服務中,我執行轉換消息併發送到遠程服務。 <messageProcessor class="org.apache.synapse.message.processor.impl.forwarder.ScheduledMessageForwardingProcesso