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");