第27章 Jakarta Messaging Bridge の設定

JBoss EAP メッセージングには、ソース宛先からメッセージを取得してターゲット宛先（通常は異なるサーバー）に送信する Jakarta Messaging ブリッジが含まれます。

Jakarta Messaging ブリッジは、各リンクが以下で定義された送信元とターゲットで設定される宛先マッピングをサポートします。

ソース宛先がトピックの場合、Jakarta Messaging ブリッジはそのサブスクリプションを作成します。client-id および subscription-name 属性が Jakarta Messaging ブリッジに設定されていると、サブスクリプションが永続化されます。これは、Jakarta Messaging ブリッジが停止後に再起動されてもメッセージがなくならないことを意味します。

ソースサーバーとターゲットサーバーは同じクラスターに置く必要はありません。このため、たとえば WAN を介して、接続が信頼できない場合に、あるクラスターから別のクラスターに確実にメッセージを送信するのにブリッジングが適しています。

<subsystem xmlns="urn:jboss:domain:messaging-activemq:4.0">
  <server name="default">
  ...
  </server>
  <jms-bridge name="my-jms-bridge" module="org.apache.activemq.artemis" max-batch-time="100" max-batch-size="10" max-retries="1" failure-retry-interval="500" quality-of-service="AT_MOST_ONCE">
    <source destination="jms/queue/InQueue" connection-factory="ConnectionFactory">
      <source-context/>
    </source>
    <target destination="jms/queue/OutQueue" connection-factory="jms/RemoteConnectionFactory">
      <target-context>
        <property name="java.naming.factory.initial" value="org.wildfly.naming.client.WildFlyInitialContextFactory"/>
        <property name="java.naming.provider.url" value="http-remoting://192.168.40.1:8080"/>
      </target-context>
    </target>
  </jms-bridge>
  ...
</subsystem>

上記の設定例では、Jakarta Messaging ブリッジは以下の 2 つの接続を作成するために connection-factory 属性を使用します。

Java Naming and Directory Interface (JNDI)を使用して接続ファクトリーを検索する Apache ActiveMQ Artemis または Red Hat AMQ によって提供されるデフォルトの実装を使用できます。他のアプリケーションサーバーまたは Jakarta Messaging プロバイダーの場合は、org.apache.activemq.artemis.jms.bridge.ConnectionFactoryFactory インターフェイスを実装して新しい実装を提供できます。

/subsystem=messaging-activemq/jms-bridge=my-jms-bridge:add(quality-of-service=AT_MOST_ONCE,module=org.apache.activemq.artemis,failure-retry-interval=500,max-retries=1,max-batch-size=10,max-batch-time=100,source-connection-factory=ConnectionFactory,source-destination=jms/queue/InQueue,source-context={},target-connection-factory=jms/RemoteConnectionFactory,target-destination=jms/queue/OutQueue,target-context={java.naming.factory.initial=org.wildfly.naming.client.WildFlyInitialContextFactory,java.naming.provider.url=http-remoting://192.168.40.1:8080})

以下の例のように、管理 CLI で read-resource コマンドを使用して Jakarta Messaging ブリッジの設定を確認できます。

/subsystem=messaging-activemq/jms-bridge=my-jms-bridge:read-resource

以下の例にあるように、write-attribute を使用して Jakarta Messaging ブリッジに設定を追加します。

/subsystem=messaging-activemq/jms-bridge=my-jms-bridge:write-attribute(name=ATTRIBUTE,value=VALUE)