activemq

ActiveMQ - 每2秒出现一次“无法发送,通道已失败”?
activemq

ActiveMQ - 每2秒出现一次“无法发送,通道已失败”?

ActiveMQ 5.7.0 CentOS 版本 6.3 Java 版本“1.6.0_26” 应用程序服务器:Tomcat 在中activemq.log,我每 2 秒就会看到一次此异常: 2013-11-05 13:00:52,374 | DEBUG | Transport Connection to: tcp://127.0.0.1:37501 failed: org.apache.activemq.transport.InactivityIOException: Cannot send, channel has already failed: ...

Admin

是否可以在 MCollective 客户端和服务器端使用不同的连接器?
activemq

是否可以在 MCollective 客户端和服务器端使用不同的连接器?

是否可以在客户端使用 STOMP 连接器并在服务器端使用 ActiveMQ?以下是我的配置: #client.cfg connector = stomp plugin.stomp.host = localhost plugin.stomp.port = 6163 plugin.stomp.user = mcollective plugin.stomp.password = password #server.cfg connector = activemq plugin.activemq.pool.size = 1 plugin.activemq.po...

Admin

ActiveMQ Artemis Federation Hub-Spoke 无法正常工作
activemq

ActiveMQ Artemis Federation Hub-Spoke 无法正常工作

我正在尝试配置三个代理 ActiveMQ Artemis (2.31.2) 的联合。我们称代理为 A、B 和 C。当我配置完整的联合网格时,A 上给定主题的消费者将收到 C 上的发布者发送到该主题的消息。但是,如果我将联合配置为最小的 Hub-Spoke A - B - C,那么 A 上的消费者将不再从 C 上的发布者那里收到消息。A 和 B 之间以及 B 和 C 之间的连接是对称上游链路。我在互联网上找不到这种 hub-spoke 配置的任何示例配置。Artemis 附带的示例都是全网格示例。Artemis 联合不能使用 Hub-Spoke 配置吗? 主题...

Admin

如何将 ActiveMQ Artemis 安装为 Windows 服务?
activemq

如何将 ActiveMQ Artemis 安装为 Windows 服务?

标题有点误导,因为我知道如何将 artemis 安装为 Windows 服务,根据文档,只需运行 artemis-service.exe install 这对我来说不起作用。我尝试使用 ActiveMQ Artemis 版本 2.31 和 2.29 安装和运行该服务。对于这两个版本,运行该服务都会生成以下日志artemis-service.wrapper.log 2023-10-23 10:19:50,116 DEBUG - Starting WinSW in the service mode 2023-10-23 10:19:50,147 INFO -...

Admin

ActiveMQ“Classic”消息代理日志中出现以下错误。我正在寻找解决方案来查找根本原因并修复此问题
activemq

ActiveMQ“Classic”消息代理日志中出现以下错误。我正在寻找解决方案来查找根本原因并修复此问题

ActiveMQ“Classic”消息代理日志中出现以下错误。我正在寻找解决方案来查找根本原因并修复此问题。 Sep 6 16:10:46 SERVER activemq_db8159[1168628]: WARN | Error while closing connection: Deadlock found when trying to get lock; try restarting transaction Sep 6 16:10:46 SERVER activemq_db8159[1168628]: java.sql.BatchUpdateEx...

Admin

ActiveMQ:处理 STOMP NACK 消息
activemq

ActiveMQ:处理 STOMP NACK 消息

STOMP 文档提到了有关 NACK 消息 https://stomp.github.io/stomp-specification-1.2.html#NACK NACK与 相对ACK。它用于告诉服务器客户端未消费该消息。然后服务器可以将该消息发送给其他客户端、丢弃该消息或将其放入死信队列。具体行为因服务器而异。 在 ActiveMQ 上下文中,“服务器特定”实际上是什么意思?在哪里可以设置行为? ...

Admin

ActiveMQ 中的负面待处理消息
activemq

ActiveMQ 中的负面待处理消息

我们有一个由 6 个 ActiveMQ 节点组成的集群。所有节点上的 ActiveMQ 版本均为 5.15.8。问题是我们在代理上随机面临待处理消息的负数。我们在 Google 上搜索了这个问题,发现有些人在旧版本上遇到了同样的问题。但我们找不到正确的答案,不知道问题是否已经解决!有人有关于这个错误的最新信息吗?它在更高版本中是否得到了解决? ...

Admin

ActiveMQ Artemis:将凭证从 Websocket 传播到 STOMP
activemq

ActiveMQ Artemis:将凭证从 Websocket 传播到 STOMP

ActiveMQ Artemis 能否将基本身份验证信息(用户名、密码)从 Websocket 传播到封装的 STOMP 协议(​​STOMP-over-Websockets)?文档在这里并没有真正的帮助。 ...

Admin

ActiveMQ Artemis:并行使用普通 TCP 和 TLS
activemq

ActiveMQ Artemis:并行使用普通 TCP 和 TLS

在 ActiveMQ Artemis 中,当同时配置了接受器和连接器时,我们会看到客户端连接到 TCP 和 TLS 端口。我们如何控制客户端保持其初始连接协议?即,通过 TLS 连接的客户端应继续使用 TLS,而不支持 TLS 的客户端应坚持使用 TCP。 <connectors> <connector name="artemis">tcp://${ipv4addr}:61616?sslEnabled=false</connector> <connector n...

Admin

ActiveMQ Artemis:客户端连接到代理集群端口
activemq

ActiveMQ Artemis:客户端连接到代理集群端口

我们正在将一些 JMS 客户端连接到在集群配置中运行的 ActiveMQ Artemis (v2.14.0) 代理。今天,我们注意到客户端连接到专用于集群通信的接受器,并且想知道为什么会发生这种情况。 以下是相关broker.xml片段: <configuration xmlns="urn:activemq" xmlns:xi="http://www.w3.org/2001/XInclude" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:ac...

Admin

带有服务器端过滤的 PUB/SUB 消息队列?
activemq

带有服务器端过滤的 PUB/SUB 消息队列?

我正在寻找一个消息队列来实现聊天应用程序。 最重要的要求是:当订阅者指定过滤条件时,所有消息都需要被过滤在服务器端。 不幸的是,我找不到明确的答案来回答这个问题:周围的所有这些 MQ 是在客户端还是在服务器端进行过滤。 在我看来,大多数 MQ 要么根本不支持过滤条件,要么在客户端进行过滤(Kafka、ZeroMQ)。 也许你们可以给我指明正确的方向? ...

Admin

activemq url 以 scp:// 开头
activemq

activemq url 以 scp:// 开头

我继承了一个系统,其中 activemq 地址如下所示scp://localhost:61616 ActiveMQ 本身似乎仅针对 进行了配置tcp。我在这里找不到对该协议的任何引用:http://activemq.apache.org/activemq-connection-uris 以前有人见过这个吗? ...

Admin

ActiveMQ Artemis:TLS 证书重新加载
activemq

ActiveMQ Artemis:TLS 证书重新加载

Apache ActiveMQ Artemis (v2.13.0) 可以在运行时使用更新的 TLS 证书吗?还是需要重新启动?我在配置传输和重新加载配置部分。 当针对短期 TLS 证书时,任何重启都会导致不必要的服务中断。 ...

Admin

ActiveMQ Artemis:无 HA 策略“缩减”的消息消耗
activemq

ActiveMQ Artemis:无 HA 策略“缩减”的消息消耗

在 ActiveMQ Artemis HA 集群 (v2.13.0) 中,<scale-down/>如果主实例发生故障,HA 策略的属性会导致备份代理将所有待处理消息移至剩余的活动实例之一。一旦耗尽,从属代理就会自行停止并等待主实例再次上线。即使只有一个主代理发生故障,此行为也会有效减少集群中的代理对数量。对吗? 如果<scale-down/>未设置该属性,则从属代理在主代理发生故障时变为活动代理,并且集群中的活动代理数量不会发生变化。但是,我想知道如果故意关闭(即SIGTERM),活动备份实例是否仍会将待处理消息移动到其他代理。此行...

Admin

ActiveMQ Artemis:仅限仲裁的实例?
activemq

ActiveMQ Artemis:仅限仲裁的实例?

对于完全冗余的 ActiveMQ Artemis 集群,需要一组三个代理对或网络 ping以避免出现裂脑情况。在某些安装中,只有两个数据中心或可用区域可用,外加一个小型的第三站点用于仲裁服务器。 是否可以将 Artemis 代理作为实际上不处理工作负载的法定人数实例运行? ...

Admin