Как настроить JM-коннектор ActiveMQ в JBoss для использования соединений XA? - PullRequest
Новая
       33

Как настроить JM-коннектор ActiveMQ в JBoss для использования соединений XA?

8 голосов
/ 02 июля 2010

На JBoss 5.1.0 у меня есть источник данных (PostgreSQL 8.3.11), настроенный с использованием * -ds.xml (стандартная jboss DS). Он использует XADataSource ( PGXADataSource ). У меня также есть брокер ActiveMQ (сейчас он работает как in-VM, под JBoss, но последний будет работать на отдельном сервере).

То, что я хочу сделать, - это заставить фабрику соединений ActiveMQ и источник данных участвовать в транзакциях XA. Например, я хочу обновить запись в БД и отправить сообщение JMS как UOW. Вы поняли.

Я настроил PGXADataSource в my-pg-ds.xml, и он работает (я могу отслеживать выполнение вплоть до метода запуска PGXAConnection ). Я попытался настроить ActiveMQXAConnectionFactory непосредственно в Spring (я использую Spring 3.0.2.RELEASE), но это не работает, потому что в этом случае диспетчер транзакций Spring (я использую аннотацию, чтобы позволить Spring настроить JtaTransactionManager , который просто делегирует всю работу менеджеру транзакций Jboss), не подключает XAResource для данного ActiveMQXAConnection . Всякий раз, когда я пытаюсь отправить сообщение, я получаю исключение JMSException, говорящее «XAResource сеанса не был зачислен в распределенную транзакцию». выбрасывается из ActiveMQXASession .

Так как это не сработало, я перешел на JCA-конфигурацию ActiveMQ ConnectionFactory (на основе этого документа), и он работает для обычного ConnectionFactory , но я не понимаю, как можно Я настраиваю его для использования XAConnectionFactory. Кажется, что Resource Adapter просто не имеет надлежащей реализации ManagedConnectionFactory, ManagedConnection и т. Д. Для фабрики соединений XA.

Я что-то упустил или у меня нет другого выбора, кроме как написать оболочки XA для адаптера ресурсов?

1 Ответ

7 голосов
/ 06 июля 2010

Хорошо, я нашел решение. Jboss включает JCA-коннектор для любой фабрики JMS (поддерживает оба типа транзакций: XA и локальные). Он находится в /server//deploy/jms-ra.rar. Вот как я это настроил.

Сначала 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 direcotry: 

<?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 вызывается для каждого компонента, созданного микроконтейнером, и проверяет аннотацию JndiBinding для этого компонента.

...