クラス GenericMessageEndpointManager

このクラスは、ResourceAdapter、MessageEndpointFactory、および ActivationSpec で機能するという点で完全に汎用的です。次のように、Spring の XML Bean 定義形式などを使用して、標準の Bean スタイルで構成できます。

<bean class="org.springframework.jca.endpoint.GenericMessageEndpointManager">
 <property name="resourceAdapter" ref="resourceAdapter"/>
 <property name="messageEndpointFactory">
   <bean class="org.springframework.jca.endpoint.GenericMessageEndpointFactory">
     <property name="messageListener" ref="messageListener"/>
   </bean>
 </property>
 <property name="activationSpec">
   <bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
     <property name="destination" value="myQueue"/>
     <property name="destinationType" value="jakarta.jms.Queue"/>
   </bean>
 </property>
</bean>

この例では、Spring 独自の GenericMessageEndpointFactory を使用して、指定されたターゲット ResourceAdapter でサポートされている標準メッセージリスナーオブジェクトを指します。この場合は、ActiveMQ メッセージブローカーでサポートされている JMS MessageListener オブジェクトで、Spring Bean として定義されています。

<bean id="messageListener" class="com.myorg.messaging.myMessageListener">
  <!-- ... -->
</bean>

ターゲット ResourceAdapter は、ローカル Spring Bean としても構成できます (一般的なケース)。または、JNDI から取得することもできます。上記の例では、ローカル ResourceAdapter Bean は次のように定義できます (上記の "resourceAdapter" Bean 参照に一致)。

<bean id="resourceAdapter" class="org.springframework.jca.support.ResourceAdapterFactoryBean">
 <property name="resourceAdapter">
   <bean class="org.apache.activemq.ra.ActiveMQResourceAdapter">
     <property name="serverUrl" value="tcp://localhost:61616"/>
   </bean>
 </property>
 <property name="workManager">
   <bean class="..."/>
 </property>
</bean>

異なるターゲットリソースの場合、構成は単に異なる ResourceAdapter および異なる ActivationSpec オブジェクト (どちらもリソースプロバイダーに固有) を指し、場合によっては異なるメッセージリスナー (たとえば、JCA 共通クライアントインターフェースに基づくリソースアダプターの CCI MessageListener ) を指すことになります。

非同期実行戦略は、上に示すように、ResourceAdapterFactoryBean の "workManager" プロパティを通じてカスタマイズできます。ここで、<bean class="..."/> は、任意の JCA 準拠の WorkManager の構成に置き換える必要があります。

トランザクションの実行は、指定された MessageEndpointFactory によって構築された具体的なメッセージエンドポイントの責任です。GenericMessageEndpointFactory は、通常、Spring JtaTransactionManager またはプレーンな TransactionManager 実装が指定されている "transactionManager" プロパティを通じて XA トランザクションへの参加をサポートします。

<bean class="org.springframework.jca.endpoint.GenericMessageEndpointManager">
 <property name="resourceAdapter" ref="resourceAdapter"/>
 <property name="messageEndpointFactory">
   <bean class="org.springframework.jca.endpoint.GenericMessageEndpointFactory">
     <property name="messageListener" ref="messageListener"/>
     <property name="transactionManager" ref="transactionManager"/>
   </bean>
 </property>
 <property name="activationSpec">
   <bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
     <property name="destination" value="myQueue"/>
     <property name="destinationType" value="jakarta.jms.Queue"/>
   </bean>
 </property>
</bean>

<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager"/>

または、リソースプロバイダーの ActivationSpec オブジェクトを確認します。このオブジェクトは、プロバイダー固有の構成フラグ (ActiveMQActivationSpec の "useRAManagedTransaction" Bean プロパティなど) を通じてローカルトランザクションをサポートしているはずです。

<bean class="org.springframework.jca.endpoint.GenericMessageEndpointManager">
 <property name="resourceAdapter" ref="resourceAdapter"/>
 <property name="messageEndpointFactory">
   <bean class="org.springframework.jca.endpoint.GenericMessageEndpointFactory">
     <property name="messageListener" ref="messageListener"/>
   </bean>
 </property>
 <property name="activationSpec">
   <bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
     <property name="destination" value="myQueue"/>
     <property name="destinationType" value="jakarta.jms.Queue"/>
     <property name="useRAManagedTransaction" value="true"/>
   </bean>
 </property>
</bean>