31.2. 使用集成 Artemis 资源适配器远程连接

JBoss EAP 包括一个资源适配器，可用于连接其集成的 ActiveMQ Artemis 消息服务器。默认情况下，messaging- activemq 子系统中定义的 pooled- connection-factory 使用适配器来进行连接。但是，您也可以使用相同的资源适配器来连接在 JBoss EAP 远程实例中运行的 Artemis 服务器。

WFLYCTL0412: Required services that are not installed:" => ["jboss.naming.context.java.jboss.DefaultJMSConnectionFactory"]

若要连接在 JBoss EAP 远程实例中运行的 Artemis 服务器，请 按照以下步骤创建新的 pooled-connection-factory ：

将 MDB 配置为使用 pooled-connection-factory

在将 pooled-connection-factory 配置为连接到远程 Artemis 服务器后，必须先使用 pooled-connection-factory 资源的名称为来自远程服务器的 Message-Driven Beans (MDB)注释掉 @ResourceAdapter 注释。

import org.jboss.ejb3.annotation.ResourceAdapter;

@ResourceAdapter("remote-artemis")
@MessageDriven(name = "MyMDB", activationConfig = { ... })
public class MyMDB implements MessageListener {
    public void onMessage(Message message) {
       ...
    }
}

如果 MDB 需要发送消息到远程服务器，则必须使用其中一个 JNDI 条目 查找 pooled-connection-factory 来注入 pooled-connection-factory。

@Inject
@JMSConnectionFactory("java:/jms/remoteCF")
private JMSContext context;

配置 JMS 目的地

MDB 还必须指定它将使用消息的目的地。执行此操作的标准方法是定义与本地服务器上的 JNDI 查找对应的 destinationLookup 激活配置属性。

@ResourceAdapter("remote-artemis")
@MessageDriven(name = "MyMDB", activationConfig = {
    @ActivationConfigProperty(propertyName = "destinationLookup", propertyValue = "myQueue"),
    ...
})
public class MyMDB implements MessageListener {
    ...
}

如果本地服务器不为远程 Artemis 服务器包含 JNDI 绑定，请指定目的地名称，如远程 Artemis 服务器中配置，使用 目标 激活配置属性，并将 useJNDI 激活配置属性设置为 false。这指示 Artemis 资源适配器自动创建 JMS 目的地，而无需 JNDI 查找。

@ResourceAdapter("remote-artemis")
@MessageDriven(name = "MyMDB", activationConfig = {
    @ActivationConfigProperty(propertyName = "useJNDI", propertyValue = "false"),
    @ActivationConfigProperty(propertyName = "destination", propertyValue = "myQueue"),
    ...
})
public class MyMDB implements MessageListener {
    ...
}

在上例中，激活配置属性将 MDB 配置为使用来自远程 Artemis 服务器上托管的名为 myQueue 的 JMS Queue 的消息。在大多数情况下，MDB 不需要查找其他目的地来处理已使用的消息，如果消息上定义了 JMSReplyTo 目标，它也可使用它。

如果 MDB 需要远程服务器上定义的任何其他 JMS 目的地，则必须使用客户端 JNDI。如需更多信息，请参阅 连接到服务器。