配置 Boomi JMS 连接器到 ActiveMQ Artemis

问题描述

我一直在 Boomi 中使用 JMS 连接器与 ActiveMQ Artemis 2.14 连接,但使用客户端库 activemq-all-5.15.11.jar 和工厂 .show-scrollbar { overflow: scroll; } or a combinator? /* former_element ~ target_element */ .div-with-no-scroll ~ .div-immediately-following-with-scroll { overflow: scroll; } you would need to remove your <br> between the div's for combinator 这有效,但我有问题连接在堆中创建大量 org.apache.activemq.jndi.ActiveMQInitialContextFactory 对象,这些对象与实际消息无关,而是与 org.apache.activemq.artemis.core.server.impl.MessageReferenceImpl 相关联。

所以我正在尝试使用 ActiveMQ Artemis 2.14 客户端设置 Boomi JMS 连接器。我将以下库导入 Atom:

  • activemq-core-5.4.1.jar
  • artemis-core-client-2.14.0.jar
  • artemis-jms-client-2.14.0.jar
  • artemis-jms-client-all-2.14.0.jar
  • fscontext-4.6-b01.jar
  • geronimo-j2ee-management_1.1_spec-1.0.1.jar

然后我创建了一个自定义库,将其设置为Connector JMS,并添加了上述库并部署到Atom。在连接器中,我指定了 ActiveMQ 和 ConectionFactory ActiveMQ.Advisory.TempQueue

这给了我一个 java 转储,抱怨“无法创建初始上下文”和“无效的代理 URL” 我的 URL 有点花哨,但它适用于其他 ActiveMQ JMS 连接器。

org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory

所以我尝试了一个简单的 URL,只是 failover:(tcp://[host]:61616,tcp://[host]:61616)?startupMaxReconnectAttempts=2&maxReconnectAttempts=0&maxReconnectDelay=1000 这给了我一个奇怪的错误:“执行过程中出现意外错误java.lang.NoClassDefFoundError:org/jboss/logging/Logger”

这是否意味着我包含了一个我不需要的库,它需要 jboss 记录器,还是我真的需要 jboss 记录器库?

对此的任何指导表示赞赏。

解决方法

这里有很多问题要讨论。我会轮流拿走。

...我遇到了在堆中创建大量...对象的连接问题,这些对象与实际消息无关,而是与 ActiveMQ.Advisory.TempQueue 相关联。

您应该能够通过在您的客户正在使用的 supportAdvisory=false 中的 acceptor 上设置 broker.xml 来解决此问题。 OpenWire chapter in the ActiveMQ Artemis user manual 中对此进行了讨论。

我将以下库导入 Atom...

您实际需要的唯一库是artemis-jms-client-all-2.14.0.jar。顾名思义,它包含所有 ActiveMQ Artemis 客户端代码以及所有依赖项(例如 Netty、JMS API 类、JBoss 日志框架等)。

在连接器中我指定了 ActiveMQ 和 ConectionFactory org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory

org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory不是 JMS ConnectionFactory 实现。它是 JNDI 的 InitialContextFactory 实现。

这给了我一个 java 转储,抱怨“无法创建初始上下文”和“无效的代理 URL”我的 URL 有点花哨,但它适用于其他 ActiveMQ JMS 连接器。

您使用的 URL 适用于用于 ActiveMQ 5.x(您之前使用的)的 OpenWire JMS 客户端。但是,它对于用于 ActiveMQ Artemis(您现在正在使用的)的核心 JMS 客户端无效。你可以使用这样的东西:

(tcp://[host]:61616,tcp://[host]:61616)?ha=true&initialConnectAttempts=2&reconnectAttempts=0&maxRetryInterval=1000