问题标签 [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.

76 问题
Newest
Active
Bountied
318
Unanswered
0 投票
1 回答
645 浏览

ssl - JMS 使用安全路由连接到在 Openshift 上运行的 Red Hat AMQ 7

我们在 Openshift 3.11 上运行 AMQ 7。尝试从 Openshift 平台使用 JMS 连接 Java 客户端时没有问题。但是，为了从外部客户端访问它，我创建了一个到 61617 端口的安全路由。在 Openshift 上，这条路线应该以https://my-route:443 的形式提供，我可以 ping my-route。但是我如何使用它来建立 JMS 连接，我不断得到：

我的代码：

和 jndi.properties ：

我必须已经使用tcp而不是https，否则我会得到“无效的代理 url”。

如果有人能指出我正确的方向，那就太棒了。

0 投票
1 回答
41 浏览

nms - .Net 中的 AMQ - 证书或凭据

是否应该同时使用信任库/密钥库和证书来通过 SSL 连接访问 AMQ 代理？如果是，如何实现这一目标？我发现为 NMS 做这件事的文章和博客非常少。我是新手。

0 投票
1 回答
51 浏览

redhat - Red Hat AMQ 中的客户端本地队列

我们有一个具有主/从配置的 Red Hat AMQ 7.2 代理网络。客户端应用程序发布/订阅代理集群上的主题。

我们如何处理客户端应用程序和代理集群之间的网络连接断开的情况？Red Hat AMQ 是否有本地解决方案，例如客户端本地队列以及本地队列和远程代理之间的 jms 到 jms 桥接，以便网络连接故障不会导致消息丢失。

0 投票
1 回答
144 浏览

apache-kafka - Kafka AMQ 流 - 主题命令

我从未使用过 AMQ Streams (Kafka)。如何通过路由（读取/创建/删除）连接到主题？对于 Kafka，例如在我的本地机器上，我使用 CLI 和基本命令。但是对于 AMQ Streams，我只有路线。它是一个 HTTPS URL。

0 投票
1 回答
75 浏览

activemq - 我可以在没有许可证/支持订阅的情况下在生产中使用 Red Hat AMQ 7.7

我可以在没有许可证或支持订阅的情况下在生产中使用 Red Hat AMQ 7.7 吗？JBoss AMQ 和 Red Hat AMQ 有什么区别？

0 投票
1 回答
235 浏览

jboss - 如何在 openshift 中扩展 JBoss AMQ 6.3？

我在 OpenShift 中有一个 JBoss AMQ 的默认设置，并希望将其扩展到两个 pod。我该如何做到这一点？

只是缩放它会导致以下结果：

0 投票
0 回答
81 浏览

kubernetes - ActiveMQ 主题消息卡住，故障后批量重新发送

环境：

  • 部署在 Kubernetes 上的 ActiveMQ
  • 使用 openwire 的生产者 Java 应用程序
  • 订阅者 Python 和 C 客户端使用 MQTT

问题陈述：

  • 生产者每秒钟在主题上发送消息，订阅者相应地接收它。

  • 但有时一天一次或三次订阅者停止接收消息大约 4 到 8 秒，然后客户端在 1 秒内批量接收所有丢失的消息。

  • 我在 ActiveMQ 中启用了调试日志，但找不到任何异常/错误或警告

以下是客户端日志

虽然没有消息丢失，但我的应用程序需要在几秒钟内更新，奇怪的是这在 24 小时内随机发生两次或三次。

Update1： ​​经过大量优化和重构后，我终于找到了根本原因

Broker Tracs 的发布者： 在此处输入图像描述

发布者假设每 12 毫秒后发送一次频率状态，但从 13:28:08.132 到 13:28:08.174 它没有发送状态，然后在一条消息中发送所有先前丢失的信息。

代理到客户端日志 在下面的日志中，我们可以看到客户端在第 175、176、176、177、181 毫秒时收到状态。客户对此很敏感，并希望每 12 毫秒后收到一条消息，而不是一次性发送所有消息

0 投票
1 回答
148 浏览

spring-boot - 使用 Red Hat AMQ 和 Spring Boot 使用 AMQP 1.0 协议实现消息服务

我必须制作一个演示项目，该项目使用 AMQP 1.0 协议和 Red Hat AMQ（基于 ActiveMQ Artemis 构建）向主题/队列发送消息并从主题/队列接收消息。但是，我找不到任何支持或示例代码。我尝试了 ActiveMQ 页面上给出的示例，但这不是很有帮助。我在哪里可以得到一个例子？

0 投票
1 回答
49 浏览

autocloseable - ActiveMQManagedConnection (EAP/AMQ) 是否支持自动关闭？

我在用：

  • 开班
    • AMQ（好像是分叉的activemq-5.11.0.redhat……版本）
  • EAP 7.2.3
  • 在本地调试时，我得到一些带有物理 ActiveMQManagedConnection 的 ~ConnectionProxy

我可以使用“try-with-resources”吗？

我不确定并且认为没有......因为 ActiveMQManagedConnection 5.11.0（我不知道 redhat 发生了什么变化）没有实现 Autoclosable。实现的 javax.resource.spi.ManagedConnection 也没有

https://github.com/apache/activemq/blob/activemq-5.11.0/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQManagedConnection.java#L53

我还没有找到这个 EAP ConnectionProxy 的来源。也许它具有自动关闭功能。

0 投票
1 回答
16 浏览

amq - 带指数退避的 AMQ 消息排序

我很好奇 AMQ 在消息重新传递和指数退避方面处理消息排序的方式。

假设您有三个消息：[M3,M2,M1]。如果我从队列头部提取 M1 消息并且我的系统无法处理它，M1 是否会回到队列头部，从而延迟它后面的所有其他消息？或者是否有一些巧妙的策略，将消息放在一边，直到准备好传送，从而允许消息 M2 和 M3 在 M1 之前处理？


12345678910