クラス 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 メッセージブローカーによってサポートされ、Spring Bean として定義されている JMS MessageListenerEE オブジェクト) を示します。

 <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 オブジェクト（どちらもリソースプロバイダーに固有）を指し、場合によっては別のメッセージリスナー（たとえば、以下に基づくリソースアダプターの CCI MessageListenerEE）を指すだけです。JCA Common Client Interface）。

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

トランザクションの実行は、指定された MessageEndpointFactory によって構築された具体的なメッセージエンドポイントの責任です。GenericMessageEndpointFactory は、通常、そこに指定された Spring JtaTransactionManager または単純な TransactionManagerEE 実装を使用して、その "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>