activemq

0熱度

4回答

有什麼方法可以獲取jms隊列中待處理消息的統計數量。我的目標是在隊列中沒有剩餘消息進行處理時關閉連接。我怎麼能做到這一點。 ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url); Connection connection = connectionFactory.createConnection(

1熱度

1回答

爲什麼在ActiveMQ中嵌入線程？

我正在檢查ActiveMQ示例，其中大部分示例都嵌入了Thread。我採取了一個例子，並刪除線程部分，並運行它，按預期工作。只是想知道線程在哪裏出現，或者它只是更適合環境或什麼？請幫我理解。謝謝。示例代碼： public class TopicConsumer implements Runnable { ActiveMQConnectionFactory connectionFact

0熱度

1回答

檢測消費者ActiveMQ主題中的變化

我有一個使用ActiveMQ主題消息的羣集的tomcat。現在，如果集羣中的一個tomcat出現故障，那麼我猜測消費者的數量會減少1. 現在，我想要在該主題上使用一些回調或偵聽器來檢測該更改。這是可行的嗎？會是這樣的：Region.getDestinations（ActiveMQDestination）的工作？

3熱度

4回答

如何在MAC OS系統中安裝ActiveMQ服務器？

如何在MAC OS X中安裝ActiveMQ服務器？無論如何，要獲得MAC OS的安裝源？以下是一些源文件，用於安裝，但不適用於MAC OS。 http://activemq.apache.org/activemq-5144-release.html 這裏是同樣的問題，但只有安裝的步驟。我可以從哪裏獲得MAC OS的源代碼？ Install & Configure ActiveMq On Mac

0熱度

2回答

使用JMS和Spring框架的ActiveMQ的生產者客戶端的重試機制

是否存在使用ActiveMQ和JMS（更確切地說，使用JmsTemplate）和Spring框架的生產者的重試機制/解決方案的機制或示例實現？我想要處理的用例是，當代理不可用時，例如，我想進行一些重試次數，最多6次（如果可能的話，每次之間有指數延遲）。所以，我還需要跟蹤每次嘗試之間的消息重試次數。我知道爲消費者重新傳遞的政策，但我也想實現一個可靠的生產者的客戶端以及感謝，西麥

-1熱度

2回答

Apache Camel：使用節流閥：如何使用配置文件更改timePeriodMillis的值？

我在apache駱駝藍圖中使用油門：throttle timePeriodMillis =「1000」 with constant = 4 我想使用佔位符動態地放置timePeriodMillis的值。這可能嗎？

0熱度

1回答

ActiveMQ的動態發現不工作的EC2

ActiveMQ的動態發現在我的原型具有這種物鏡不工作：甲JMS客戶端應用程序（消息生產者），該負載平衡請求消息發送到多個（2）JMS消費者應用程序。有3個亞馬遜T2微型EC2實例爲此原型運行 - 每個實例都運行activemq 5.14.4。 <networkConnector name="frontEnd->WMR1" uri="static:(tcp://<publicip>:61616

1熱度

1回答

當生產環境中ActiveMQ的隊列已滿時該怎麼辦？

這是一個面試問題 - 在生產環境中ActiveMQ的隊列已滿時該怎麼做？應該丟棄下一條消息;或者我應該自己實現一個緩衝區還是將其存儲在數據庫中？我想知道實際生產環境中的一般解決方案。

0熱度

1回答

通過ActiveMQ發送和接收PDF

我想通過駱駝路由將PDF發送到ActiveMQ隊列。我需要在另一條駱駝路線中提取這些PDF。我無法從隊列中提取數據。我也試過.marshal().base64()。數據到達Message Broker，但我無法解壓縮。錯誤之後會出現： Exception in thread "main" java.lang.NoClassDefFoundError: org/springframework/

1熱度

2回答

彈簧引導xa事務數據源和jms

我使用spring-boot-starter-data-jpa和spring-boot-starter-activemq製作POC。我想在jpa事務提交時在代理（activeMQ）上推送jms消息。我的代碼： UtilsateurService與有「主」交易： @Service public class UtilisateurService { @Autowired