问题标签 [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 投票
2 回答
2039 浏览

apache-camel - 带有 Camel 基础的 ActiveMQ

我已经在谷歌上搜索了一段时间,寻找解释 ActiveMQ 与 Camel 的设置和集成的分步教程,但没有成功找到基本教程。我已经有一个正在运行和配置的 ActiveMQ 服务器,但是我无法启动和运行 Camel 组件。它总是创建一个单独的代理,我只是无法让 Camel 连接到现有的代理实例。

在哪里可以找到有关如何集成 Camel 并更好地理解这两者如何协同工作的基本教程的任何提示?请不要参考 Camel-Website,因为这与 ActiveMQ 的文档一起是我的主要来源来解决这些问题,但它在设置、配置和理解这两个包方面只提供了一点帮助。

谢谢

0 投票
1 回答
45 浏览

wso2 - 如何使用 WSO2ESB 使用来自 AMQ 的数据

您好我创建了一个队列,它将数据推送到队列但无法获得任何响应。它给出的响应为“警告 - 读取请求后 SourceHandler 连接超时:http-incoming-5 Socket Timeout”。我还想从该队列中获取消息。提前致谢。

0 投票
1 回答
93 浏览

java - Apache Camel .when() 语句只有一半的时间有效

我有一个带有多个 .when() 案例的 .choice() 语句。但是,我每次都上传相同的文件,其中 MsgFmtVerNr=2 有时它会转到其他文件,有时它会通过 .when().xpath("/UpsBas/MsgHdr/MsgFmtVerNr = '2'")。我不知道为什么这个语句只在一半的时间内有效。是否有某些原因会直接跳到 .otherwise() 语句?感谢您的帮助。

0 投票
3 回答
2598 浏览

java - activemq 内存使用量是最大堆分配的 4 倍

我的 java actvemq 进程有以下配置,其中 Xmx 为 15360M 但是当我使用 Glance 看到内存的进程使用情况时,我看到 RSS 41.8gb 和 VSS 51.6gb 。pmap |grep total 给我总计 54059348K。我不确定 activemq 中发生了什么导致使用了这么多内存。虽然堆使用率非常低,直到 60%。

在 pmap 的输出中,我看到了很多匿名块。请找到附加的 PMAP 输出

请在此处找到 pmap 文件

0 投票
1 回答
540 浏览

ansible - 使用 ansible 从 Karaf 终端执行结构命令

在 ansible 中,我们如何在 Karaf 终端中执行结构命令。

实际上在 ansible 中我们会执行 shell 命令,但是有一些命令我需要用 Karaf 终端执行。有没有可能做。

一般来说,如何使用 ansible playbook 打开除 shell 之外的其他终端

0 投票
1 回答
2458 浏览

spring - 如何在 JmsTemplate 中发送标头消息?

我正在尝试将消息头插入 amq。JMSTemplate 中没有用于在 amq 中设置标头的特定方法。当我这样设置时,它将保存在StringProperty而不是标题中。为了保存到标题中如何传递数据

我需要将数据发送到标头中,客户端将为我的消息标头实现选择器。

0 投票
1 回答
1624 浏览

testing - 如何使用 RabbitMQ 处理蓝/绿部署?

在我们的云环境中,当部署新实例时,我们会运行集成测试。但是,它变得棘手,因为新代码正在为正在部署的服务在队列中注入消息,而现有实例(以前的版本)仍在运行。我们有一个蓝/绿部署。

RabbitMQ 是否有可能让许多侦听器在队列上侦听但仅针对特定版本?

例如,所有正在运行的服务器都会读取版本 2017.10.20(以前的版本)或更早版本的消息,但它们不会读取新版本的消息。

这样我就可以部署一个新的服务,而其他的 Droplet 都不会读取它的测试消息。

正在部署的新服务具有与现有服务相同的功能。它产生和使用与当前运行的服务相同的消息类型。

0 投票
1 回答
215 浏览

apache-camel - jms过期,AMQ->MQ系列

在将消息从 AMQ 队列移动到 IBM MQ 系列队列期间,我们试图在消息中保留 TimeToLive/JMSExpiration,目前我们使用:AMQ 中的 jmsBridgeConnectors 来移动消息,但不保留过期时间。我知道 AMQ 建议宁愿使用 Camel 而不是 jmsBridgeConnectors 将 AMQ 连接到外部消息传递系统,但我没有使用 Camel 的经验。

有没有人遇到过类似的问题并有一些可行的解决方案,无论是使用 jmsBridgeConnectors 还是 Camel?

非常感谢您向 Lukasz 致以最诚挚的问候

0 投票
0 回答
2105 浏览

jboss - WFLYEJB0383: 在资源适配器 activemq-rar.rar 中找不到 javax.jms.MessageListener 类型的消息侦听器

我在尝试启动 Jboss 7.1 时看到了上述错误。请帮忙!注意,文件 activemq-rar.rar 位于standalone\deployments 目录中。此外,这是我对standalone\configuration\standalone.xml 文件所做的相关更新(请注意以下是缩写的.. xml 格式正确)。另请注意,我能够使此设置与 JBoss 6 一起使用。

0 投票
0 回答
3702 浏览

java - activemq 或通用 JMS 消息大小是否有最大大小?

我所能找到的只是消息大小没有特定限制,但它由分配给 JVM 的堆内存决定。无论如何,较小的消息更好。我正在尝试使用 activemq 发送 1Gb 文件而不会遇到内存不足错误,我读过使用 artemis 的人设法使用 50Mb 的 ram 完成 8Gb,发送 1Gb 至少需要 4Gb(使用amq 的 Blob 方法)。有人知道为什么吗?