问题标签 [activemq-artemis]

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 回答
782 浏览

java - Eclipse paho 连接到分布式代理

我使用 Apache Artemis 作为我的 mqtt 代理。我有一个以主从方式配置的 Artemis 集群。当主服务器发生故障时,备份服务器接管,客户端必须连接到从服务器。主从有不同的IP。

在 eclipse paho 中创建 MqttClient 对象时,是否可以选择指定多个连接 url(主从地址)?

就像是

而不仅仅是

这样当与第一个地址的连接失败时,将尝试与下一个地址的连接。

有人可以指导吗?非常感激。

0 投票
1 回答
791 浏览

websocket - 如何将 WildFly 10.1.0Final Apache Artemis 1.1.0 更新到 Apache Artemis 1.3

我已经安装了 WildFly 10.1.0。Final II 在 Javascript 中创建了一个 Stomp over Websocket 客户端来直接连接到 Artemis 中的主题。

我连接了一个订阅两个客户端,但是当我关闭或取消订阅两个客户端之一时,其他客户端会发现接收消息。

我找到了一个完全描述相同问题的邮件列表。

http://activemq.2283324.n4.nabble.com/STOMP-server-quits-sending-to-all-subscribers-when-one-client-disconnects-td4713980.html

一位名为“johndament”的用户提到自动创建功能修复了此错误(在 v1.3 中)。然后“Ed Kaltenbach”解决了将 WildFly 10.1.0.Final 随附的 ActiveMQ artemimis 版本从 v1.1.0 更新到 v1.3 的问题

可以帮我更新版本和推荐吗?

野蝇阿尔忒弥斯 1.1.0

这些是从官方网站下载并解压 ActiveMQ 1.3 后的文件:

ActiveMQ 阿尔忒弥斯 1.3

0 投票
1 回答
105 浏览

activemq - Apache ActiveMQ Artemis 中的 Moquette internalPublish 等效函数

internalPublishApache ActiveMQ Artemis 中是否有等效的 Moquette函数?我需要在我的代码中从代理内部发布一些消息。有人可以告诉我如何在 ActiveMQ Artemis 中做到这一点吗?

0 投票
1 回答
367 浏览

spring-transactions - 从 ActiveMQConnectionFactory 创建经过身份验证的 XA 资源

我有一个 Apache ActiveMQ Artemis (1.3) 实例,我正在尝试从我的团队目前正在开发的独立 Spring (4.3.2) 应用程序连接到该实例。它具有使用 Atomikos (4.0.4) UserTransactionManager作为提供者的 Spring JTATransactionManager,在这些事务中我需要连接到多个资源,包括上述 MQ。按照 Artemis 和 Atomikos 手册,我们设置了ActiveMQConnectionFactory,然后将其传递给AtomikosConnectionFactoryBean。这一切都发生在一个 Spring 容器中,但这似乎与我们的问题无关。

在我尝试向 MQ 连接添加身份验证之前,一切都运行良好。可以在ActiveMQConnectionFactory的实例上设置用户密码属性,但是,它们似乎仅在创建普通连接时才考虑在内:

Atomikos 正在调用createXAConnection () 方法(来自XAConnectionFactory接口),正如我在其实现中看到的那样,除非明确传递,否则忽略凭据:

这也是此类中其他一些方法的工作方式,因此我认为这不是错误。如果是这样,我应该如何获得经过身份验证的XAConnection?我看不到 Atomikos 调用重载版本的可能性,查看它的代码。

问候, 雅库布

0 投票
2 回答
11378 浏览

jms - 如何将 JMS 消息从 WildFly 10 发送到远程 ActiveMQ

在互联网上摸索了这么多之后,令人惊讶的是,我找不到使用带有 ActiveMQ (Artemis) 的 WildFly 10 中的 JMS 推送到远程消息队列的示例配置。更糟糕的是,这种情况standalone-full.xml并没有绑定到模式(为什么???),当我终于在 GitHub 上找到了它的 XSD 时,它没有包含说明每个节点/属性的含义以及可以放入什么值的文档。

下面是来自standalone-full.xml 的原始配置。

下面是我的 CDI 队列客户端,它能够将消息发布到 WildFly 中的本地 Artemis 实例。

我的目标:将消息发布到远程ActiveMQ 实例。

我所拥有的:server url、、topic name和。usernamepassword

我的问题:如何修改配置以实现此目标?

替代问题:如果无法回答上述问题,我该如何实现这个目标?

谢谢!

0 投票
1 回答
2570 浏览

java - 使用 Core API 连接到 ActiveMQ Artemis Docker 容器

我正在尝试使用 ActiveMQ Artemis Core API 连接到在 docker 容器中运行的 ActiveMQ Artemis。

我正在使用以下代码尝试连接。

运行时,当我尝试创建会话工厂时出现以下错误。

ActiveMQNotConnectedException[errorType=NOT_CONNECTED message=AMQ119007: Cannot connect to server(s). Tried with all available servers.]

在尝试连接到 ActiveMQ Artemis 代理时,我似乎错过了一个关键的配置步骤。我是否需要将 XML 文件放在我的 Java 客户端应用程序中的某个位置,或者我可以在代码中设置正确的设置吗?

我正在使用的 AtiveMQ Artemis 的 Docker 映像:

https://github.com/vromero/activemq-artemis-docker

0 投票
1 回答
3014 浏览

jms - WildFly 10 Artemis 和 ActiveMQ 5.14 之间的 JMS 桥接(ONCE_AND_ONLY_ONCE 服务质量)

我正在尝试在 Artemis(在 WildFly 10 中运行)和 ActiveMQ 5.14 之间建立一个 JMS 桥

通常,该过程似乎运行顺利,但不幸的是,我陷入了使 ONCE_AND_ONLY_ONCE QoS 正常工作所必需的 XA 配置上。

尽管消息确实到达了 ActiveMQ 端,但我在 WildFly 日志中收到以下错误:

我的问题类似于这个(Wildfly 10 ONCE_AND_ONLY_ONCE JMS 桥),但不幸的是,该解决方案并不完全适用于我的情况,因为我的目标是 ActiveMQ 5.14。

从我读过的所有帖子看来,我应该确保桥两侧的连接工厂应该配置为 XA 支持。在 Artemis 方面,这似乎很简单:只需将 factory-type="XA_GENERIC" 添加到定义中。但是,我无法弄清楚如何在 ActiveMQ 端执行此操作。

这是我的standalone-full.xml 中指定我的消息传递子系统的片段:

对于 ActiveMQ 定义,我使用了资源适配器,定义如下:

一些正确方向的指针将不胜感激

格雷格

0 投票
3 回答
9808 浏览

spring-boot - Spring boot Artemis 嵌入式代理行为

大家早,

我最近一直在努力使用 spring-boot-artemis-starter。我对其 spring-boot 支持的理解如下:

  • 设置spring.artemis.mode=embedded,并且像 tomcat 一样,spring-boot 将实例化通过 tcp (服务器模式)可访问的代理。以下命令应该成功:nc -zv localhost 61616
  • setspring.artmis.mode=native和 spring-boot 只会根据spring.artemis.*属性(客户端模式)配置 jms 模板。

客户端模式适用于我机器上的独立 artemis 服务器。不幸的是,我永远无法在服务器模式下访问 tcp 端口。

如果有人确认我对嵌入式模式的理解,我将不胜感激。

感谢您的旅行帮助

经过一番挖掘,我注意到 spring-boot-starter-artemis 提供的开箱即用的实现使用了org.apache.activemq.artemis.core.remoting.impl.invm.InVMAcceptorFactory接受器。我想知道这是否不是根本原因(同样我绝不是专家)。但似乎有一种方法可以自定义 artemis 配置。因此,我尝试了以下配置,但没有任何运气:

0 投票
0 回答
124 浏览

jboss - How configure the Error Queue in Jboss EAP7.0

Planning to migrate the Weblogic JMS to Jboss EAP 7 - messaging-activemq. In weblogic , We have a weblogic error queue configuration as below

Could you please let me know how to configure the ErrorQueue in Jboss EAP 7 and also I tried to configure DLQ but it will not work same as weblogic error-destination queue.

Thanks much

0 投票
1 回答
540 浏览

java - 如何在 WildFly 上升级 Artemis

我们正在使用 Artemis 1.1.0.wildfly-017 附带的 WildFly 10.1.0.Final,我们希望将其升级到最新的维护版本1.1.0.SP18-redhat-1(也考虑 1.4.0) .

如何在无需手动构建 WildFly 的情况下升级 Artemis?