Apache ActiveMQ是一个开源(Apache 2.0许可)消息代理,它完全实现了Java Message Service 1.1(JMS)。它提供了“企业功能”,如群集,多个消息存储,以及将任何数据库用作除VM,缓存和日志持久性之外的JMS持久性提供程序的能力。
我们的API可以使用ActiveMQ向我们的workerhost服务发送消息。 activemq:故障转移:(tcp://brokera.domain.net:21249,tcp://brokerb.domain.net:21249)?maxReconnectAttempts=2&timeout=3000&
我的消息队列中包含多条消息。我想按特定属性进行分组。这些都有一个自定义属性“item-id” 我现在将某些价值观定为:体育、电影...... 我确实...
我希望能够使用 Spring Boot 应用程序取消发送到队列(ActiveMQ Classic)的消息。我已经实现了一个小功能来帮助我从队列中删除消息,但它......
ActiveMQ Classic 5.x 兼容哪个版本的 JMS?我的印象是答案是1.1。 ActiveMQ Classic 6.x 与哪个版本的 JMS 兼容?我的印象是答案我...
停止 Spring JMS 侦听器会导致 ActiveMQ Classic 上出现奇怪的行为
在启动和停止 JMS 侦听器时,我遇到了一些奇怪的行为。我已经定义了两个监听器,如下所示: @JmsListener(id="myid", 目的地 = "myDestination") 公开
ActiveMQ Classic 中分组消息的消耗存在较大延迟
我们有一个经纪人网络,由位于不同服务器上的三个经纪人组成。 网络连接器配置如下: 我们有一个经纪人网络,由位于不同服务器上的三个经纪人组成。 网络连接器配置如下: <networkConnectors> <networkConnector uri="static:(ssl://broker2:61616,ssl://broker3:61616)" networkTTL="5"/> </networkConnectors> 整体设置如下图所示。 在实践中,我们有时会看到特定客户端的消息消费存在较大延迟。在这种情况下,消息在最终被使用之前会被多次转发到其他代理。到目前为止,我们还无法找出可能的原因。 消费者不是很忙。它们是使用 Spring JMS 库实现的。每个经纪人的最小消费者数量为 3 个,但这可以根据需要自动扩展。 我们怀疑只有特定客户端受到影响的原因可能与我们使用 JMSGroupId 来获取消息处理方式的一些顺序有关。然而,我们没有确实的证据证明这一点。但它仍然无法解释为什么会发生这种情况。 我们还考虑向网络连接器添加以下参数,因为我们认为这可能会改善行为: dynamicOnly="true" decreaseNetworkConsumerPriority="true" suppressDuplicateQueueSubscriptions="true" 然而,这样做也很可怕,因为我们觉得我们不完全了解现在正在发生的事情,因此无法真正确定这些设置将对行为产生的影响。 我们怀疑只有特定客户受到影响的原因, 可能与我们使用 JMSGroupId 的事实有关 了解如何处理消息的一些顺序。 宾果游戏。 如果确保串行消息处理,则扩展消费者是没有用的。摆脱这种行为的最佳方法是设置一个专用的 JMS 队列,每个组有一个消费者,否则当队列中的多个后续消息属于同一组时,您将尝试消费者争用。 参见 JMS 拓扑(具有多个消费者的队列)和消息组
ActiveMQ Classic JDBC Master Slave 持续存在 JDBC 问题,无法使用 MySQL 8 连接器锁定 MySQL 数据库
仅使用 JDBC 作为数据源时,您可以使用运行两个代理的主从方法(即一个用于主代理,另一个用于从代理)。我正在使用 MySQL 8 连接器用于 MySQL 5.7 和...
找出ActiveMQ日志中“failed to parse jmxUrl”的含义
我们收到以下错误,但我们没有更改任何内容。尽管 activemq 仍在运行,但我们想了解“无法解析 pid:11404 的 jmxUrl”的含义。
我正在尝试使用 ActiveMQ 集群和 Virtual Topics 创建一个高可用的消息系统,用于 K8s 集群内的服务间通信,但遇到了启动问题...
我想使用 ActiveMQ 故障转移传输,如 https://activemq.apache.org/failover-transport-reference.html 中所述。 默认的“永远重试”故障转移选项的工作方式为 exp...
为什么我会收到此错误?用于连接Camel和ActiveMQ的配置是正确的
无法找到类路径资源[META-INF/spring/jmsContext.xml]中定义的名为“amqConnectionFactory”的bean的类[org.apache.activemq.ActiveMQConnectionFactory]; 谁能告诉我什么是
我曾从事过 IBM MQ 工作,这是我从事 ActiveMQ 的第一个项目。阅读基本教程后,我发现两者很相似。所以我开始创建小应用程序来听
我正在寻求帮助来确定 Apache ActiveMQ“Classic”的官方支持生命周期。 ActiveMQ 网站指出: 一旦 Artemis 达到足够的功能水平...
将 ActiveMQ Classic Web 控制台与 Tomcat 9.x 集成
我尝试按照ActiveMQ Classic官方文档将activemq-web-console.war放入Tomcat webapps文件夹中,将activemq-all.jar放入Tomcat lib中,但Web控制台无法启动。 我尝试过 Tomcat 5...
activeMq redeliveryPolicy 从 tomee 传递到 spring 时被忽略
我在 tomee 1.7.1 和 activeMq 5.10 中部署了一个简单的 spring 应用程序。 我的问题是,我设定的重新投递政策似乎主要被忽略了重新投递的延迟。 我是我的 jms 听众,我立即...
Spring boot 3.2.0 使用 JMS 进行单元测试,因为无法连接任何嵌入式 ActiveMQ Broker 我该怎么做?
我想创建与EmbeddedActiveMQBroker的连接,并且还想在消息中设置字符串属性,以便侦听器可以从消息中提取这些字符串属性。我想使用 Message.clas...
带有外部 ActiveMQ 的 JBoss FUSE 7.4 给出 AMQ219013:等待接收集群拓扑超时。组:空
我正在尝试连接到 JBoss FUSE 7.4 (fuse-karaf-7.4.0.fuse-740028-redhat-00001) 上的 ActiveMQ Classic 消息代理。我找到了下面的例子。 我已经下载并安装了相关的
我已经搜索了很多,但我不明白为什么,我的java安装正确。而且环境属性也是正确的。 尝试在 Windows 7 64 位中安装 ActiveMQ。 这是
将 ActiveMQ Classic 从 5.10.1 升级到 5.17.6 - 无法启动代理服务 - NoSuchMethodError
我尝试在 Windows Server 2019 上将 ActiveMQ Classic 从 5.10.1 升级到 5.17.6。我下载并解压缩了新的安装文件夹。 从旧的安装文件夹中,我复制了 conf 和 data 文件夹...
升级 WebSphere 类路径中的 JAR 后,未连接到 ActiveMQ Classic。 以前的 JAR: activemq-client-5.14.5.jar hawtbuf-1.11.jar slf4j-api-1.7.13.jar 更新的 JAR: 活动...