activemq

1熱度

3回答

從動態隊列（ActiveMQ）（待定郵件= 1000）中讀取郵件時，我已經確認了每條郵件，現在郵件已出隊數量= 1000。是否有任何方法將所有出隊郵件再次放入隊列中。任何解決方案，以物理方式獲得所有消息的備份。預先感謝

1熱度

3回答

Mule Persistent ActiveMQ RedeliveryPolicy

我正在使用Mule作爲ESB解決方案。我有一個隊列，從那裏我收到消息，並試圖使HTTP請求服務，始終失敗。我已經配置了RedeliveryPolicy上的ActiveMQ這樣的： <spring:bean id="retryRedeliveryPolicy" class="org.apache.activemq.RedeliveryPolicy" name="retryRedeliv

1熱度

1回答

ActiveMQ使用zookeeper複製levelDB，客戶端必須知道所有代理？

客戶端必須知道所有使用故障轉移傳輸的代理，對不對？像這樣，故障轉移：（tcp：// broker1：61616，tcp：// broker2：61616，tcp：// broker3：61616）是否存在優化，以便客戶端不必知道每個經紀人？

1熱度

1回答

ActiveMQ transferExchange不再在駱駝工作？

我正在嘗試升級我們的應用程序之一的駱駝版本。但似乎我不能再使用「transferExchange」選項通過ActiveMQ/JMS發送屬性。我寫了一個小測試程序： public static void main(String args[]) throws Exception { CamelContext context = new DefaultCamelContext();

1熱度

1回答

多種配置MQ或ActiveMQ監聽器的方式

有人可以解釋配置監聽器的不同方式嗎？我知道有兩種方式：春JMS偵聽 EJB MDB方式。是否有其他方法（應該適用於IBM MQ和Active MQ）？

2熱度

2回答

針對不同源系統和單個消費者的活動MQ併發性

我有這個問題，即在我的隊列中存在來自不同源系統的消息。例如：在第一條消息中，我的源系統名稱爲'X'，第二條消息中，源系統名稱爲：'Y'。目前我有一個併發級別設置爲1的JMS監聽器。因此，所有消息都按照預期一個接一個地處理，但現在我想同時處理消息，以便如果消息來自同一個源系統，那麼只有一個應該一次爲該源系統處理消息，並且如果存在針對不同源系統的消息，則它們必須並行執行。源系統正在動態創建，這就

0熱度

2回答

如何從「org.apache.activemq.command.Message」獲取actievmq隊列的大小？

我想覆寫BrokerFilter類的send（）方法。此方法有兩個參數：ProducerBrokerExchange和Message。我可以從這兩個參數中獲得目標隊列的大小嗎？我使用的是activemq-all-5.13.2.jar。

0熱度

2回答

ConnectionFactory在駝峯前被破壞

我正在使用spring-boot與camel和ActiveMQ。我通過@EnableJms註釋使用activemq autoconfiguration。但創建我自己的ActiveMQComponent在所有隊列上啓用「事務處理（true）」。 @Bean(name = "activemq") @ConditionalOnClass(ActiveMQComponent.class) publ

0熱度

1回答

Spring Boot和長時間運行的任務

在我的Spring Boot應用程序中，我必須實現一個導入服務。用戶可以提交一堆JSON文件，應用程序將嘗試從這些文件中導入數據。根據JSON文件的數據量，單個導入過程可能需要1或2個小時。我不想在導入過程中阻止用戶，所以我打算接受導入任務並通知用戶此數據計劃處理。我將把數據放入隊列中，另一端的空閒隊列使用者將開始導入過程。另外，我需要有可能監視隊列中的作業，並在需要時終止它們。現在我正在考慮

3熱度

1回答

如何在.NET中創建核心使用AMQP.Net精簡版庫持久發佈/訂閱話題的clientId和用戶名和主題名稱

我是新來ActiveMQ，但我想和我能夠創建一個持久的出版商，但我無法設置客戶端ID，因爲我沒有找到客戶端ID的任何屬性，甚至無法在Google中找到。如果我能得到一些示例代碼，這將非常有幫助。注意：不符合NMS協議。我在.NET Core Web API中使用了ActiveMQ的AMQP.Net Lite，用於創建具有ClientId的持久發佈者/訂閱者。