activemq

    1熱度

    1回答

    我使用Spring JMS DefaultMessageListenerContainer,並初始化spring的init方法上的隊列,並銷燬destroy方法上的listnereContainer。 但是當我關閉使用「./catalina.sh停止」命令,我收到以下異常Tomcat服務器時,我的工具線程轉儲: ‘本地主機-startStop-2’#155守護PRIO = 5 Object.wai

    0熱度

    1回答

    我是新來的ActiveMQ,並試圖找到任何明確地規定JMSMessageID按如何與長期訂閱和選擇的行爲,但是,我苦苦尋找了。 作爲示例:JMSType ='car'AND color ='blue'AND weight> 2500作爲選擇器。每個訂閱者只會接收標準匹配主題的消息。當每個接收到的消息都是每個訂閱者唯一的JSMMessageID時,或者它們在整個話題被用戶的選擇器過濾之前是唯一的。

    0熱度

    1回答

    是否可以使用駱駝路由發送活動mq中的wsdl請求正文。如果是,我可以在下面實現的是我的示例代碼,其中im試圖發送隊列中的wsdl請求正文,但沒有發生。 <route id="report"> <from id="_from2" uri="direct:reportIncident"/> <to id="_to3" uri="activemq:queue:in.incid

    0熱度

    1回答

    我們有兩個運行activeMq(Artemis)的wildlfy 10.1.0服務器。我們希望兩個artemis與消息同步。如果一個人失敗了,另一個人應該開始接收和發送消息。谷歌缺乏文檔以及artemis是新的。 此外,保持兩者都是負載平衡的活動狀態,這有可能嗎?

    0熱度

    3回答

    因此,使用JMS和ActiveMQ,我可以確定,使用JmsTemplate從我的Spring Boot應用程序發送的消息即使在發送消息到ActiveMQ時目標應用程序關閉,也會到達它的目標應用程序。當目標應用程序啓動時,它會從隊列中抓取消息。大! 但是, 如果我的Spring Boot應用程序嘗試向ActiveMQ服務器上的隊列發送JMS消息,但ActiveMQ服務器在此時關閉或網絡關閉,並且出現

    0熱度

    1回答

    我有一個mqtt客戶端連接到一個經紀人。 我的經紀人攔截連接以從中獲取令牌並執行一些操作。 我想連接時發送一個令牌作爲查詢參數。 我的客戶端連接是這樣的: MqttAsyncClient sampleClient = new MqttAsyncClient(broker, clientId, persistence); MqttConnectOptions connOpts = ne

    0熱度

    1回答

    我想在我的隊列中的一個應用一個TTL使用以下的插件代理配置適用timeStampingBrokerPlugin:timeStampingBrokerPlugin 這是我第一次使用插件,我試圖添加將以下代碼放入policyEntry部分: <policyEntry queue="test1"> <plugins> <timeStampingBrokerPlugin ttlCei

    0熱度

    3回答

    我是這個ActiveMQ的新手。我有這樣的場景,我有兩個ActiveMQ的節點,有點像這樣: amq1.url=http://abcd01.xxxxxxxxxxx:8041/api/message/ amq2.url=http://abcd02.xxxxxxxxxxx:8041/api/message/ 我想在我的@PostConstruct方法這兩個節點的是這是建立和運行,以查找並使用UR

    -1熱度

    2回答

    我試圖從使用駱駝路由的隊列讀取消息並將其發送給消息監聽器的bean,但它以異常結束。難道我做錯了什麼。在ActiveMQ的 <bean class="com.herman.cxf.incident.ReportIncidentRequestConsumer" id="requestConsumer" /> <camelContext id="camelContext-32

    0熱度

    1回答

    有沒有什麼辦法讓消耗的消息,我想因爲ActiveMQ的