activemq

    2熱度

    1回答

    我最近發現Spring有一個利用jms(ActiveMQ虛擬目標)的spring雲流提供程序的alpha版本。這絕對有趣,我想測試一下。我很難找到我可以使用的依賴關係的快照,或者能夠拉取和構建正確的github項目,因此我在本地存儲庫中擁有依賴關係。我將不勝感激這方面的任何援助。 http://activemq.apache.org/amqp.html https://github.com/spr

    0熱度

    1回答

    我有一個Java應用程序,使用我認爲是相當鍋爐板的JMS代碼來連接和接收來自ActiveMQ服務器的消息。 this.consumerFactory = new ActiveMQConnectionFactory(this.ingestItemBrokerUrl); this.consumerConnection = this.consumerFactory.createConnection()

    0熱度

    1回答

    我想在我的Windows 64位服務器上安裝apache mq 1.7.1,它在創建代理實例時向我顯示錯誤,如下圖所示。 請注意我在我的機器上安裝了java 8,所有的路徑變量等都已到位,請幫忙。

    0熱度

    1回答

    我想在Spring-JMS中實現一個帶有activeMQ的解決方案,我想創建持久訂閱主題。其目的是,如果用戶關閉了一段時間的訂閱,並再次使用相同的客戶端ID和訂閱名稱重新創建durablesubscription,則訂閱者應該收到訂閱結束時的所有消息。 我想要實現在ORACLE網址爲長期訂閱提到以下邏輯:https://docs.oracle.com/cd/E19798-01/821-1841/b

    2熱度

    1回答

    我試圖創建一個SpringBoot駱駝應用程序(用於測試)。我配置了SpringBoot和Camel-Spring。它似乎在工作,但不知何故它發送數據到activemq(通過SendBody)失敗。 的applicationContext.xml <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springfram

    0熱度

    1回答

    在我的場景中,生產者正在將消息發送到隊列(與往常一樣:),但消費者中的一個不時關閉,所以我必須能夠讀取所有消息在消費者關閉時發送到該隊列。換句話說,我正在尋找消息或整個服務器的配置,允許消費者重新連接後接收消息,而消息是事先發送的。 更準確地說,當客戶端重新連接時,它無法接收隊列中掛起的消息。我需要的是強制新連接的客戶端接收隊列中已經掛起的消息,以幫助其他客戶端解除隊列。

    0熱度

    1回答

    我有一個單步執行的spring批處理作業。我正在使用JMSItemReader,其中jmstemplate是會話事務處理的,而我的作者只是執行一些業務邏輯。每當任何異常發生默認情況下,重試耗盡,然後自動批量大小變爲1,並逐一爲所有項目。 我正在定義這樣的步驟。 stepBuilderFactory.get("step") .<String, String> chunk(10)

    0熱度

    1回答

    我有一個場景, 我有相同的隊列配置爲SMS和EMAILS。 我希望ActiveMQ將消息路由到特定的使用者池,即如果它是SMS,則必須將其路由到工作線程池以用於SMS。 所以,如果我需要擴大SMS的數量,那麼我只需要增加SMS Worker Pool的池大小而不是EMAIL工作池。 我可以使用Apache Camel來實現我的需求的路由邏輯嗎?

    0熱度

    1回答

    我試圖使用log4j JMSappender和ActiveMQ進行POC。我成功地遵循這個例子 - >http://activemq.apache.org/how-do-i-use-log4j-jms-appender-with-activemq.html 但這是爲INFO級別。我做了一些修改,在DEBUG級別使用它,我的程序和activeMQ不能交換它們的線路格式。這裏是我的log4j(客戶端)

    1熱度

    1回答

    我在Docker容器中運行Wildfly。 在wildfly中,messaging-activemq子系統處於活動狀態。 子系統和擴展默認值取自standalone-full.xml文件。 wildfly啓動後,顯示以下輸出 [org.apache.activemq.artemis.jms.server] (ServerService Thread Pool -- 64) AMQ121005: