如何在 JBoss 中配置 ActiveMQ JCA 连接器以使用 XA 连接？

在 JBoss 5.1.0 上，我使用 *-ds.xml （标准 jboss DS）配置了数据源（PostgreSQL 8.3.11）。它使用 XADataSource (PGXA数据源 http://jdbc.postgresql.org/development/privateapi/org/postgresql/xa/PGXADataSource.html）。我还有 ActiveMQ 代理（现在它在 JBoss 下作为虚拟机内运行，但后者将在单独的服务器上运行）。

我想做的是让ActiveMQ连接工厂和数据源参与XA事务。例如，我想更新数据库记录并以 UOW 形式发送 JMS 消息。你明白了。

我在 my-pg-ds.xml 中配置了 PGXADataSource 并且它可以工作（我可以一路跟踪执行情况PGXAConnection的启动方法 http://jdbc.postgresql.org/development/privateapi/org/postgresql/xa/PGXAConnection.html#start%28javax.transaction.xa.Xid,%20int%29）。我尝试过配置ActiveMQXAConnectionFactory http://activemq.apache.org/maven/activemq-core/apidocs/org/apache/activemq/ActiveMQXAConnectionFactory.html直接在Spring中（我使用Spring 3.0.2.RELEASE），但这不起作用，因为在这种情况下Spring事务管理器（我使用注释让Spring配置Jta事务管理器 http://static.springsource.org/spring/docs/3.0.2.RELEASE/javadoc-api/org/springframework/transaction/jta/JtaTransactionManager.html它只是将所有工作委托给 Jboss 事务管理器）不会为给定的情况征用 XAResourceActiveMQXA连接 http://activemq.apache.org/maven/activemq-core/apidocs/org/apache/activemq/ActiveMQXAConnection.html。每当我尝试发送消息时，都会收到异常 JMSException，指出“会话的 XAResource 尚未在分布式事务中登记”。抛出自ActiveMQXA会话 https://svn.apache.org/repos/asf/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQXASession.java.

由于这不起作用，我已切换到 ActiveMQ ConnectionFactory 的 JCA 配置（基于this http://activemq.apache.org/integrating-apache-activemq-with-jboss.html文件）并且它适用于常规连接工厂 http://docs.oracle.com/javaee/5/api/javax/jms/ConnectionFactory.html，但我不明白如何配置它以使用 XAConnectionFactory。这好像是资源适配器 https://svn.apache.org/repos/asf/activemq/trunk/activemq-ra/根本没有 XA 连接工厂的正确 ManagedConnectionFactory、ManagedConnection 等实现。

我是否遗漏了某些内容，或者我别无选择，只能为资源适配器编写 XA 包装器？

好的，我找到了解决方案。 Jboss 包括适用于任何 JMS 工厂的 JCA 连接器（支持两种类型的事务：XA 和本地）。它位于/server//deploy/jms-ra.rar。这是我的配置方法。

First, activemq-jms-ds.xml文件进入 jms-ra.rar 旁边的部署目录：

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE connection-factories
    PUBLIC "-//JBoss//DTD JBOSS JCA Config 1.5//EN"
    "http://www.jboss.org/j2ee/dtd/jboss-ds_1_5.dtd">

<connection-factories>
    <mbean code="org.jboss.jms.jndi.JMSProviderLoader"
       name="jboss.messaging:service=JMSProviderLoader,name=ActiveMQJMSProvider">
        <attribute name="ProviderName">ActiveMQJMSProvider</attribute>
        <attribute name="ProviderAdapterClass">org.jboss.jms.jndi.JNDIProviderAdapter</attribute>
        <attribute name="FactoryRef">java:/activemq/XAConnectionFactory</attribute>
        <attribute name="QueueFactoryRef">java:/activemq/XAConnectionFactory</attribute>
        <attribute name="TopicFactoryRef">java:/activemq/XAConnectionFactory</attribute>
    </mbean>

    <tx-connection-factory>
        <jndi-name>JmsXAConnectionFactory</jndi-name>
        <xa-transaction/>
        <rar-name>jms-ra.rar</rar-name>
        <connection-definition>org.jboss.resource.adapter.jms.JmsConnectionFactory</connection-definition>
        <config-property name="JmsProviderAdapterJNDI" type="java.lang.String">java:/ActiveMQJMSProvider</config-property>
    </tx-connection-factory>
</connection-factories>

这告诉 Jboss 查看 jms-ra.rar 并找到可以提供托管连接工厂的适配器org.jboss.resource.adapter.jms.JmsConnectionFactory。内部jms适配器依赖于JmsProviderAdapter，它用于存储连接工厂的JNDI名称（在我的配置中所有名称都是相同的）。

我使用 mbean 标签来配置 JMSProviderLoader （这是从内部 JBoss 配置之一复制的）。现在，我所要做的就是以某种方式创建 XA 连接工厂的实例并将其绑定到java:/activemq/XAConnectionFactory。有多种方法可以做到这一点（例如，实现 MBean 包装器）。

由于我是 Jboss 5，所以我使用了微容器（这可能在 Jboss 6 中工作）。我添加了activemq-jms-jboss-beans.xml文件到deployers目录：

<?xml version="1.0" encoding="UTF-8"?>
<deployment xmlns="urn:jboss:bean-deployer:2.0">
    <!-- Define a Jndi binding aspect/annotation that exposes beans via jndi
        when they are registered with the kernel.
    -->
    <aop:lifecycle-configure xmlns:aop="urn:jboss:aop-beans:1.0"
        name="DependencyAdvice"
        class="org.jboss.aop.microcontainer.aspects.jndi.JndiLifecycleCallback"
        classes="@org.jboss.aop.microcontainer.aspects.jndi.JndiBinding"
        manager-bean="AspectManager"
        manager-property="aspectManager">
    </aop:lifecycle-configure>

    <bean name="ActiveMQXAConnectionFactory" class="org.apache.activemq.ActiveMQXAConnectionFactory">
        <annotation>@org.jboss.aop.microcontainer.aspects.jndi.JndiBinding(name="activemq/XAConnectionFactory", aliases={"java:/activemq/XAConnectionFactory"})</annotation>
        <property name="brokerURL">vm://localhost</property>
    </bean>
</deployment>

我创建一个ActiveMQXAConnectionFactory豆。为了将其绑定到 JNDI，我使用 JndiBinding 注释对其进行注释。为了使这个注释起作用，我们需要 JndiLifecycleCallback。据我所知，JndiLifecycleCallback 会在微容器创建的每个 bean 上调用，并检查该 bean 上的 JndiBinding 注释。