问题标签 [amq]

用例是创建一个 microservice-http-endpoint AWS lambda 函数，该函数将消息发布到 Amazon ActiveMQ，我尝试搜索相同但找不到​​答案，是否可以从 AWS lambda 函数向 AMQ 发布消息？

谷歌搜索

不适用

不适用

我们有我们的本地 Active-MQ，我正在探索 AWS 中用于托管消息传递服务的选项。我们所有的应用程序都使用 ActiveMQ 的虚拟主题功能。看来在 AWS 中，扇出可以使用 SNS->SQS 来实现。但遗憾的是，SNS 支持 SQS 标准队列，还不支持 FIFO 队列。当消息排序也很重要时，实现扇出案例的最佳方法是什么？

我们也可以使用 Kinesis 和 AWS ActiveMQ。但是对于 Kinesis，我无法想象如何在 Kinesis 中实现 VirtualTopic 功能。分片如何在多个主题中工作。

那么，使用 SQS-SNS 在 AWS 世界中实现 ActiveMQ 虚拟主题功能的最佳方法是什么？

我正在使用 node.js 的 stompit 包连接到 AMQ 队列以订阅消息。我使用ConnectFailover类来创建连接和channelPool类来创建池。

我面临的问题是，一旦建立连接并且如果队列中没有消息，那么它就会保持连接。

如果没有要从队列中读取的消息，我需要一种断开连接的方法。我在stompit 文档中看不到任何选项。

我正在向 AMQ 队列发送 XML 消息。XML 有标题部分。我需要将标头的子节点设置为 AMQ 消息的属性。我正在使用 NodeJS stompit 包。

当前消息仅显示一个属性，即 JMSXDeliveryCount。

我有两个企业网络段 - 绿色（可以访问 Internet）和红色（内部网络）。所以，它是这样工作的：互联网 ↔ 绿色 ↔ 红色。

两个部分中的每一个都有自己的 Red Hat Fuse、Red Hat AMQ（或 ActiveMQ）、Apache Camel 包——为简单起见，我们称这个包为“套件”。该套件在两个细分市场中都是相同的，用于集成。绿色和红色之间的所有流量都通过 Suite-Suite 对传递。一端的套件接收流量，以某种方式打包，通过消息代理 (AMQ) 发送，然后另一端的套件将其解包并将其发送到所需的节点。因此，Suite-Suite 就像某种防火墙和隔离/检查软件一样使用。

可悲的是，对于一般交通转移案例，Suite-Suite 转移是一项要求。我知道这会损害性能并且它并不优雅。

问题是：通用的 TCP 流量（即 http 和 gRPC 流量）如何被 AMQ/ActiveMQ 包装并在段之间透明地承载？

如何组织这种交流？例如，我考虑将流量放入 SOCKS5 隧道之类的东西中，然后为 AMQ 包装 SOCKS5 流量（通过将其转换为 AMQP 等）。

我也知道可以使用 Apache Camel 为 AMQ 编写连接器，因此可以这样完成： 流量 ↔ 拦截器 ↔ 套件 ↔ AMQP 或其他 AMQ-AMQ 协议 ↔ 套件 ↔ 解码器和发送器 ↔ 流量。

提前致谢！
我正在尝试/需要将文件从 FTP 写入 AMQ 队列。原因 - 我正在尝试使用 Camel JMS AMQ 在我的路由上添加故障转移。我是 Apache ActiveMQ JMS 的新手。我在 2 个单独的节点上有 2 个 AMQ 代理。在其他 2 个节点/服务器上，我有我的 JBoss Fuse Karaf Containers 客户端应用程序。我正在从客户那里连接到经纪人。AMQ 控制台、日志等。但是，我无法从 FTP 或电子邮件路由将文件写入队列。我猜我做错了什么，希望你能帮助解决这个问题。我想知道这是否可以在我尝试这样做时完成？

AMQ 代理节点配置片段 - 两者都相同，我尝试删除任何相关的超时。没有差异。

活动MQ.xml

节点 2

系统配置文件

使用故障转移传输的客户端

路线形成 - 我有一个动态路线构建器，我将配置放入其中以创建路线

从 STR 到 STR 的路线

路线创建

有效路线

我在代理节点上得到什么

客户端似乎正在关闭连接而不传输文件？可以这样做还是完全可以这样做。文件将从 500K 到 1 GB。
系统在 xfr 尝试后挂起，必须回收。

我无法从 Red Hat AMQ 运行一个简单的队列示例。它显示以下错误：

这是我的 pom.xml：

如果您知道出了什么问题，请用更新的 pom.xml 回复。我更容易解决问题，而不是只说我应该做什么。

Idk 出了什么问题，我只想运行一个 amq-broker 示例...这是我的完整 settings.xml（我刚刚添加了 jboss-amq-maven-repository 配置文件并添加了 jboss-amq-maven-repository 作为我的活动配置文件，休息是完全默认的......）。

在尝试解决这个问题时，我几乎尝试了所有方法......但我不知道该怎么办了。

这是发生的事情的一个实际示例：

这是来自示例目录的我的 POM.xml

我们正在创建一个 Mule 应用程序，它将在 Kubernetes 上的容器中运行，并将位于将连接到 JMS 2.0 Red Hat AMQ 7（基于 ActiveMQ Artemis）的副本集中。

pom.xml 已配置为获取 jms 客户端：

JMS 配置配置为：

然后在 JMS 监听组件中：

变量设置为：

这是配置客户端的最佳方式吗？正如我们在部署到 K8s 时在日志中看到有关与 AMQ 服务器的连接的错误：

我正在研究使用 Red Hat AMQ 7.5.0 并生成 Red Hat AMQ 7.5.0 的服务的自动化集成测试。我知道您可以通过 REST 进行生产和消费，但此服务是管道的一部分，一旦将数据放入队列，它可能会快速发送到下一步。

有没有办法查看或以其他方式验证消息已通过队列？我想验证是否发送了特定消息，或者理想情况下某种 JSON 搜索会很棒（即，搜索已通过具有某些键/值对的消息）。