问题标签 [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.
java - Eclipse paho 连接到分布式代理
我使用 Apache Artemis 作为我的 mqtt 代理。我有一个以主从方式配置的 Artemis 集群。当主服务器发生故障时,备份服务器接管,客户端必须连接到从服务器。主从有不同的IP。
在 eclipse paho 中创建 MqttClient 对象时,是否可以选择指定多个连接 url(主从地址)?
就像是
而不仅仅是
这样当与第一个地址的连接失败时,将尝试与下一个地址的连接。
有人可以指导吗?非常感激。
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 中的主题。
我连接了一个订阅两个客户端,但是当我关闭或取消订阅两个客户端之一时,其他客户端会发现接收消息。
我找到了一个完全描述相同问题的邮件列表。
一位名为“johndament”的用户提到自动创建功能修复了此错误(在 v1.3 中)。然后“Ed Kaltenbach”解决了将 WildFly 10.1.0.Final 随附的 ActiveMQ artemimis 版本从 v1.1.0 更新到 v1.3 的问题
可以帮我更新版本和推荐吗?
这些是从官方网站下载并解压 ActiveMQ 1.3 后的文件:
activemq - Apache ActiveMQ Artemis 中的 Moquette internalPublish 等效函数
internalPublish
Apache ActiveMQ Artemis 中是否有等效的 Moquette函数?我需要在我的代码中从代理内部发布一些消息。有人可以告诉我如何在 ActiveMQ Artemis 中做到这一点吗?
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 调用重载版本的可能性,查看它的代码。
问候, 雅库布
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
和。username
password
我的问题:如何修改配置以实现此目标?
替代问题:如果无法回答上述问题,我该如何实现这个目标?
谢谢!
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 映像:
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 定义,我使用了资源适配器,定义如下:
一些正确方向的指针将不胜感激
格雷格
spring-boot - Spring boot Artemis 嵌入式代理行为
大家早,
我最近一直在努力使用 spring-boot-artemis-starter。我对其 spring-boot 支持的理解如下:
- 设置
spring.artemis.mode=embedded
,并且像 tomcat 一样,spring-boot 将实例化通过 tcp (服务器模式)可访问的代理。以下命令应该成功:nc -zv localhost 61616
- set
spring.artmis.mode=native
和 spring-boot 只会根据spring.artemis.*
属性(客户端模式)配置 jms 模板。
客户端模式适用于我机器上的独立 artemis 服务器。不幸的是,我永远无法在服务器模式下访问 tcp 端口。
如果有人确认我对嵌入式模式的理解,我将不胜感激。
感谢您的旅行帮助
经过一番挖掘,我注意到 spring-boot-starter-artemis 提供的开箱即用的实现使用了org.apache.activemq.artemis.core.remoting.impl.invm.InVMAcceptorFactory
接受器。我想知道这是否不是根本原因(同样我绝不是专家)。但似乎有一种方法可以自定义 artemis 配置。因此,我尝试了以下配置,但没有任何运气:
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
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?