activemq

    0熱度

    1回答

    我有一個Glassfish服務器(4.1.2)和以下this tutorial我已將Apache ActiveMQ集成到服務器。之後,我根據this part of the same tutorial開發了一個獨立的客戶端進行消息傳遞。完成之後我跟着last part of this tutorial開發了一個MessageDrivenBean,監聽之前步驟中使用的隊列。 一切正常編譯。 Acti

    0熱度

    1回答

    我在設置JMS時遇到了問題。我嘗試使用Active MQ和OpenJMS,但發生同樣的錯誤。關於如何解決這個問題蔭無言以對: 當我執行此: import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException; import java.util.Hashtabl

    0熱度

    1回答

    我想使用JMS和ActiveMQ將應用程序中的對象發送到另一個應用程序。 org.springframework.jms.support.converter.MessageConversionException: Failed to resolve type id [com.wajdi.act.Message]; nested exception is java.lang.ClassNotFoun

    0熱度

    2回答

    我在這裏已經一個代碼。我的代碼用於獲取表中的每一行的內容(int),並不斷髮送給ActiveMQ。當表更新時,新行的內容將被髮送到ActiveMQ。 但是,當我停止進程並重新運行,它會發送所有內容,從行0 - 所有的ActiveMQ的。我希望我可以把它只是不斷髮出,它不是之前發送並正常工作作爲再次照常內容... 我想我必須創建一個新的數據庫表,以節省每一個最後的限制(行計數號)在循環中,所以我可以

    -1熱度

    1回答

    我已經通過bitnami google cloud vm創建了activeMQ,我不知道要使用哪個URL,要發送消息的URL是什麼?

    1熱度

    2回答

    我正在閱讀JMS 2.0規範,並且提到(如下相關摘錄),如果客戶端嘗試修改Message對象,那麼JMS提供者可能會拋出異常。 我的問題是JMS提供程序如何知道客戶端是否嘗試修改Message對象,因爲Message對象將通過線路傳輸,並且在JMS提供者端它不是同一個堆對象,所以即使客戶端修改了消息對象,JMS提供者無法檢測到更改。 我錯過了什麼嗎? 7.3.9。關於使用消息對象的限制 應用其中執

    2熱度

    1回答

    我想通過WSO2 ESB發送ActiveMQ上的jms消息。我沒有從WSO2中找到任何屬性來設置JMS消息expiry time。我已經嘗試下面的屬性,但沒有奏效。 <property name="JMS_PROD_TIME_TO_LIVE" scope="transport" type="STRING" value="15000"/> 任何人都可以請幫忙嗎?

    0熱度

    1回答

    爲什麼這個路由拋出exceprion,我該如何解決這個問題? 監製: from("rmi:endpoint"). .setHeader(JmsHeaders.DELIVERY_MODE, constant("PERSISTENT")) .to(ExchangePattern.InOut, "activemq:myQueue?requestTimeout=86400000"); 消費者: f

    0熱度

    1回答

    假設我有3個訂戶A,B,C代表一個主題,並且我希望A,B被視爲「同一訂戶」,這意味着他們只能獲得每個消息的一個副本。而C又有了一份。 我發現http://activemq.apache.org/virtual-destinations.html是一種方式。但是如果我不能更改activemq代理的配置呢? 我不知道是否有一些「id」道具,可以讓兩個訂戶被視爲一個嗎?像kafka中的組ID?

    0熱度

    1回答

    我想建立幾個使用消息代理髮送和接收消息的微服務:ActiveMQ。現在我探索消息類型選項(即String,byte[],對象型): 發佈味精XML/JSON格式,一旦收到它們被解析 在XML發佈味精/ JSON格式,採用的架構將它們轉換爲對象 創建域對象,並加入到微服務依賴於數據交換 這些都是3個選項我已經看了看,我傾向於選擇1下面提到的原因: 當一個新的領域有待只加那些需要這個領域需要改變微服務