activemq

1熱度

2回答

在我們的設置中，我們希望在緩慢的使用者使ActiveMQ代理運行內存不足（或接近內存不足）以及稍後持久（如KahaDB）達到一定限度。到目前爲止，我只發現sendFailIfNoSpace設置，這將導致生產者方面的異常。任何其他方式獲得這些通知（例如，作爲一個單獨的主題的建議性消息）用於監控目的？閾值可能低於實際限制以提供及時的警告。

0熱度

1回答

ActiveMq：持久隊列和離線系統

我是ActiveMQ技術的新用戶，並且我遇到了一些接近此技術的問題。我有以下情況：我有SW，在嵌入式（離線）ARM設備上運行，在運行時間upluggable硬盤上存檔的一組視頻。有時（每天4-5個事件），我必須將警報事件關聯到這些視頻，並將警報排隊在持續隊列中。每月一次，我們要提取的硬盤，並連接到另一臺嵌入式在線 ARM設備，應當通知有關由離線ARM設備產生的告警一的ActiveMQ服務器

0熱度

1回答

CLI命令刪除ActiveMQ主題

我在Ubuntu 16.04上運行ActiveMQ，並通過編輯activemq.xml添加了一個主題。在代理節點添加以下節點並重新啓動的ActiveMQ： <destinations> <topic physicalName="topic1" /> <topic physicalName="topic2" /> </destinations> 當我去我的管理面板，我可以看

0熱度

2回答

如何在文本文件中搜索字符串使用Apache Camel

我是Apache駱駝的新手。有誰知道如何使用駱駝來處理文本文件的內容，以檢查文本文件中是否存在特定的字符串，例如「錯誤」。我似乎不能通過Java下面的第一行。任何幫助將不勝感激 from("file://inputdir/").convertBodyTo(String.class).

0熱度

1回答

在隊列之間傳遞數據 - Stomp

是否可以在跺腳隊列之間共享數據？我們有一個新項目，我的任務是將數據從一個隊列傳遞到另一個隊列。考慮一個使用ActiveMQ和Stomp的系統。在這個系統中，我找到了一個消息，它由queue1返回並傳遞給queue2。這對我來說沒有多大意義。任何意見關於這個問題將不勝感激。使用案例：我有這樣的應用程序：隊列1：從LDAP作出查詢，並找到用戶隊列2：使查詢從Exchange服務器給用戶我想使

0熱度

1回答

JMS跨應用程序部署在同一個tomcat之間的消息傳遞

我有兩個Web應用程序並部署在同一個tomcat服務器中。我想從app1發送jms消息到app2。我創建JMS連接工廠和生產使用APP1春天JMS（使用嵌入式活躍MQ代理網址爲VM：//本地主機）但是，當我創建APP 2的JMS客戶端，消費者是無法接受消息。如何在app2 web應用程序中共享相同的工廠實例/隊列？我需要修改server.xml以共享conn工廠等嗎？

0熱度

1回答

從activemq.xml文件讀取代理配置並使用Java代碼啓動代理

我想要讀取some_dir/activemq.xml文件，以便我可以使用org.apache.activemq.broker.BrokerService創建代理，根據提供的文件進行配置。我嘗試以編程方式設置屬性： TransportConnector tc = new TransportConnector(); tc.setName("openwire"); tc.setUri

0熱度

1回答

amq-broker無法在ServiceMix中啓動

0熱度

1回答

爲什麼Spring JMS在連接到ActiveMQ Broker時每秒創建一個JMS連接？

我創建了一個使用版本4.1.2.RELEASE的Spring JMS應用程序，該應用程序連接到運行ActiveMQ 5.11.0的代理。我看到的問題如下。在日誌中，我注意到每秒都會看到一個連接被創建爲這樣。 2017-06-21 13：10：21,046 | level = INFO | thread = ActiveMQ Task-1 | class = org.apache.activemq.

3熱度

1回答

Spring Boot嵌入式ActiveMQ持久消息

在我的Spring Boot應用程序中，我配置了嵌入式Apache ActiveMQ。 @Configuration @EnableJms public class ActiveMQConfig { @Bean public Queue queue() { return new ActiveMQQueue("import.decisions.queue");