问题标签 [amq]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
0 回答
94 浏览

java - 使用 AMQ 5.5.1 配置 JMS 附加程序

当我尝试从 HermesJMS 向 activeMQ 发送消息时,我遇到了异常。

发现需要将 JMS appender 配置为与 AMQ 对话,如此处的 建议

但我不确定在 AMQ 5.5.1 中的何处添加/修改这段代码。它是 log4j.properties 文件吗?有人可以帮忙吗?

0 投票
2 回答
781 浏览

activemq - 在 ActiveMQ 或 Fuse AMQ 中使用 JMX 识别主代理?

是否可以使用 JMX 或其他机制识别 ActiveMQ/Fuse AMQ 主/从配置中的“主”代理?我们正在创建一个仪表板,并希望直观地显示哪个服务器正在积极处理流量。

0 投票
1 回答
1016 浏览

jms - ActiveMQ 5.11 代理网络和主/从组配置

在 ActiveMQ /A-MQ 5.11 中,我想构建一个代理拓扑:

  • 4 个主/从对(2 个在拉斯维加斯,2 个在纽约)
  • 经纪人网络
  • 完整图(每个主控连接到所有其他主控)

    文档说每个代理都应该使用masterSlaveURI 连接到其他主/从组:

..所以对于这个拓扑,

在此处输入图像描述

..networkConnectors拉斯维加斯的主/从对(为简洁起见省略纽约)应该是:

vegas-A1,A2 ...连接到 B,C,D 主/从组

vegas-B1,B2 ...连接到 A,C,D 主/从组

问题

这个配置正确吗?

0 投票
2 回答
572 浏览

wso2 - WSO2 ESB + activeMQ

我是 wso2 esb 和 jms 的新手。我从soapUI 向wso2 esb 发送了一些消息。在我的 wso 序列中,一条已处理的消息会发送到 jms。是否有可能从 wso2 esb 设置此消息的“生存时间”?还是其他一些方法?

在 AMQ 我添加了这个:

<property name="JMSExpiration" value="today+hour_long_value" scope="transport" type="STRING"></property> 顺序这样的东西没有效果。

0 投票
2 回答
1551 浏览

failover - ActiveMQ 故障转移超时随机工作

我面临超时故障转移选项的问题。基本上我想要一个不断向代理发送消息的客户端,如果代理关闭,它将尝试重新连接,直到代理再次启动。同时,发送将超时,因此它不会永远挂起。

但是,经过一些测试,超时选项似乎无法正常工作。有时,它确实超时,但有时,它只是挂在那里。我知道另一个选项是 maxReconnectAttempt。但问题是我希望它尝试永远重新连接。

以下是我正在使用的网址:

我有一个两服务器系统。一个充当经纪人,一个充当客户。当我将代理切换为启动/停止时,我收到以下日志消息:

如您所见,第二次代理宕机时,它没有超时超过一小时。

下面是我正在使用的代码:

0 投票
1 回答
534 浏览

activemq - 将数据从 Kahadb 迁移到 MKahadb

我正在从 KahaDB 更改为 MKahaDB。因此,将我的一些队列分配到不同的目的地。但我想将旧队列的数据迁移到新创建的目的地。有谁知道,我该怎么做?

0 投票
1 回答
388 浏览

jboss - 在 JBoss AMQ 6.3 上部署骆驼组件时出错

我正在尝试使用 JBoss AMQ 6.3 在托管在大型机上的 WebSphere MQ 和在分布式环境中运行的应用程序之间充当桥梁。为了使它工作,我已经成功地安装了 WebSphere MQ 的 OSGi 库并部署了一个骆驼组件文件:

一开始启动JBoss AMQ时组件刚刚部署,但一周后它不再能够启动,抛出以下错误:

我怀疑它在收到来自 WebSphereMQ 的第一条消息后停止工作

0 投票
1 回答
1139 浏览

python - 从 stomp API 设置预取限制

AMQ文档指出,可以在建立连接时设置预取限制 - 有没有办法在实例化队列连接时使用stomp.py设置预取限制?

0 投票
1 回答
281 浏览

jms - ActiveMQ 提醒旧消息

我正在使用 ActiveMQ,并希望为在队列中等待很长时间的消息生成警报。我查看了“咨询信息”功能,但没有这样的规定。使用不会在 AMQ 上增加太多开销的解决方案对我来说非常重要。

注意:此要求与消息在过期后移动到 DLQ 时的警报有很大不同。

0 投票
2 回答
507 浏览

java - 如何在消息发送到 DLQ 之前处理消息

我正在使用以下服务器端重新交付配置

如何设置自定义端点以在重试后和发送到 DLQ 之前处理失败的消息?我确实参考了以下链接,但找不到有关服务器端或 redeliveryPlugin 配置的任何内容

1.死信通道

2.记录骆驼异常并发送到死信通道