第14章 メッセージング

1. 設定オブジェクトのインスタンス化

   設定ファイルから、もしくはプログラムを使用して設定パラメーターを指定することにより設定オブジェクトをインスタンス化します。

   • ファイルから設定オブジェクトを作成します。

     FileConfigurationImpl クラスを使用して、ファイルをベースとした設定オブジェクトを設定します。

     import org.hornetq.core.config.Configuration;
     import org.hornetq.core.config.impl.FileConfiguration;
     ...
     Configuration config = new FileConfiguration();
     config.setConfigurationUrl(<replaceable>file-url</replaceable>);
     config.start();
     

     Copy to Clipboard Toggle word wrap

   • プログラムを使用して設定オブジェクトを作成します。

     1. ConfigurationImpl クラスを使用して設定オブジェクトを作成します。

        import org.hornetq.core.config.Configuration;
        import org.hornetq.core.config.impl.FileConfiguration;
        ...
        Configuration config = new ConfigurationImpl();
        

        Copy to Clipboard Toggle word wrap
     2. acceptors などの任意の設定パラメーターを指定します。例:

        HashSet<TransportConfiguration> transports = new HashSet<TransportConfiguration>();
              
        transports.add(new TransportConfiguration(NettyAcceptorFactory.class.getName()));
        transports.add(new TransportConfiguration(InVMAcceptorFactory.class.getName()));
        
        config.setAcceptorConfigurations(transports);
        

        Copy to Clipboard Toggle word wrap

2. サーバーをインスタンス化して起動します。

   org.hornetq.api.core.server.HornetQ 静的メソッドを使用して、設定オブジェクトをベースとするサーバーを作成して起動します。

   import org.hornetq.api.core.server.HornetQ;
   import org.hornetq.core.server.HornetQServer;
   ...
   HornetQServer server = HornetQ.newHornetQServer(config);
   server.start();
   

   Copy to Clipboard Toggle word wrap

1. Enterprise Application Platform で JMS サブシステムを有効化

   <extensions> 要素にて、以下の行が存在しておりコメントアウトされていないか確認してください。

   <extension module="org.jboss.as.messaging"/>

   Copy to Clipboard Toggle word wrap

2. 基本的な JMS サブシステムの追加

   メッセージングサブシステムが設定ファイルに存在しない場合は、追加します。
   1. お使いのプロファイルに該当する <profile> を検索し<subsystems> タグの場所を探します。
   2. <subsystems>タグのすぐ下に新しい行を追加します。以下をそこに貼り付けます。

      <subsystem xmlns="urn:jboss:domain:messaging:1.0">
      
      </subsystem>
      

      Copy to Clipboard Toggle word wrap
      その他の設定はすべて、その上の空いている行に追加します。

3. JMS の基本設定を追加

   <journal-file-size>102400</journal-file-size>
   <journal-min-files>2</journal-min-files>
   <journal-type>NIO</journal-type>
   <!-- disable messaging persistence -->
   <persistence-enabled>false</persistence-enabled>
   

   Copy to Clipboard Toggle word wrap
   要件にあわせ上記の値をカスタマイズ

4. HornetQ に接続ファクトリインスタンスを追加

   クライアントは、JMS ConnectionFactory オブジェクトを使い、サーバーへの接続を確立します。JMS 接続ファクトリオブジェクトを HornetQ に追加するには、<jms-connection-factories> タグを１つ、接続ファクトリごとに<connection-factory> 要素を以下のように追加します。

   <subsystem xmlns="urn:jboss:domain:messaging:1.0">
     ...
     <jms-connection-factories>
       <connection-factory name="myConnectionFactory">
         <connectors>
           <connector-ref connector-name="netty"/>
         </connectors>
         <entries>
           <entry name="/ConnectionFactory"/>           
         </entries>
       </connection-factory>
     </jms-connection-factories>
     ...
   </subsystem>
   

   Copy to Clipboard Toggle word wrap

5. netty コネクターの設定

   この JMS 接続ファクトリは、netty コネクターを利用します。これは、サーバー設定ファイルにデプロイされたコネクターオブジェクトへの参照です。コネクターオブジェクトは、実際にサーバーへ接続する際に利用するトランスポートとパラメーターを定義します。
   netty コネクターを設定するには、以下の設定を含めます。

   <subsystem xmlns="urn:jboss:domain:messaging:1.0">
     ...
     <connectors>
       <netty-connector name="netty" socket-binding="messaging"/>
       <netty-connector name="netty-throughput" socket-binding="messaging-throughput">
         <param key="batch-delay" value="50"/>
       </netty-connector>
       <in-vm-connector name="in-vm" server-id="0"/>
     </connectors>
     ...
   </subsystem>
   

   Copy to Clipboard Toggle word wrap
   コネクターは、messaging および messaging-throughput ソケットバインディングを参照します。messaging ソケットバインディングは、ポート 5445 を使い、messaging-throughput ソケットバインディングはポート 5455 を使います。 以下のソケットバインディングが <socket-binding-groups> 要素に含まれているよう確認してください。

   <socket-binding-groups>
     ...
     <socket-binding-group ... >
       <socket-binding name="messaging" port="5445"/>
       <socket-binding name="messaging-throughput" port="5455"/>
       ...
     </socket-binding-group>
     ...
   </socket-binding-groups>
   

   Copy to Clipboard Toggle word wrap

6. キューインスタンスを HornetQ に追加

   クライアントは JMS Queue オブジェクトを使いサーバーへ配信する送信メッセージを段階分けします。JMS キューオブジェクトを HornetQ に追加するには、以下のように <jms-queue> 要素を含めます。

   <subsystem xmlns="urn:jboss:domain:messaging:1.0">
     ...
     <jms-destinations>
       <jms-queue name="myQueue">
         <entry name="/queue/myQueue"/>
       </jms-queue>
     </jms-destinations>
     ...
   

   Copy to Clipboard Toggle word wrap

7. オプション：トピックインスタンスを HornetQ に追加

   クライアントは JMS Topic オブジェクトを使い、複数のサブスクライバー向けにメッセージを管理します。JMS トピックオブジェクトを追加するには、 <topic> 要素を以下のように主組めます。

   <subsystem xmlns="urn:jboss:domain:messaging:1.0">
       ...
       <topic name="myTopic">
           <entry name="/topic/myTopic"/>
       </topic>
       ...
   

   Copy to Clipboard Toggle word wrap

8. 追加設定

   追加設定が必要な場合、EAP_HOME/docs/schema/jboss-messaging.xsd の DTD を確認してください。

手順14.1 タスク

1. クライアント側で JNDI プロパティを設定

   JNDI プロパティにより JNDI クライアントに JNDI サーバーがどこにあるか伝えます。このプロパティをクライアントのクラスパスにあるjndi.properties のという名前のファイルで指定するか、あるいは最初の JNDI コンテキストの作成時に直接宣言することができます。
   JNDI プロパティを以下の構成に設定

   java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
   java.naming.provider.url=jnp://hostname:1099
   java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces

   Copy to Clipboard Toggle word wrap
   • hostname は JNDI サーバーのホスト名あるいは IP アドレスです。

2. JNDI サーバーポートの設定

   1. 管理コンソールの Socket Binding Groups パネルに移動します。

      コンソールの左側のメニューから General Configuration Socket Binding Groups オプションを選択します。
      選択したサーバーの Socket Binding Groups パネルが表示されます。
      

      View larger image

      

      図14.1 サーバー設定

   2. JNDI ソケットバインディングの編集

      Socket Binding Declarations の表から jndi を選択し、下にある ソケットバインディング の Edit ボタンを選択してください。
      以下の設定と Multicast Port の設定を行い、設定後、Save ボタンを押します。
      • Port:1099
      • Multicast Port:1098

• アドレス設定とパターン属性の設定

  管理 CLI または管理コンソールを選択して、必要に応じてパターン属性を設定します。

  • 管理 CLI を使用したアドレス設定

    管理 CLI を使用してアドレスを設定します。

    1. 新しいパターンの追加

       add 操作を使用して、新しいアドレス設定を作成します (必要な場合)。このコマンドは、管理 CLI セッションのルートから実行できます。この場合、以下の例では、 patternname というタイトルの新しいパターンが作成され、max-delivery-attempts 属性が 5 として宣言されます。full プロファイルのスタンドアロンと監理対象ドメインの編集の例が示されます。

       [domain@localhost:9999 /] /profile=full/subsystem=messaging/hornetq-server=default/address-setting=patternname/:add(max-delivery-attempts=5)

       Copy to Clipboard Toggle word wrap

       [standalone@localhost:9999 /] /subsystem=messaging/hornetq-server=default/address-setting=patternname/:add(max-delivery-attempts=5)

       Copy to Clipboard Toggle word wrap

    2. パターン属性の編集

       write 操作を使用して新しい値を属性に書き込みます。タブ補完を使用して、入力するコマンド文字列を補完したり、利用可能な属性を公開したりできます。以下の例は、max-delivery-attempts 値を 10 に更新します。

       [domain@localhost:9999 /] /profile=full/subsystem=messaging/hornetq-server=default/address-setting=patternname/:write-attribute(name=max-delivery-attempts,value=10)

       Copy to Clipboard Toggle word wrap

       [standalone@localhost:9999 /] /subsystem=messaging/hornetq-server=default/address-setting=patternname/:write-attribute(name=max-delivery-attempts,value=10)

       Copy to Clipboard Toggle word wrap

    3. パターン属性の確認

       read-resource 操作で include-runtime=true パラメーターを実行して値を変更し、サーバーモデルでアクティブな現在のすべての値を公開します。

       [domain@localhost:9999 /] /profile=full/subsystem=messaging/hornetq-server=default/address-setting=patternname/:read-resource

       Copy to Clipboard Toggle word wrap

       [standalone@localhost:9999 /] /subsystem=messaging/hornetq-server=default/address-setting=patternname/:read-resource

       Copy to Clipboard Toggle word wrap

  • 管理コンソールを使用したアドレスの設定

    管理コンソールを使用してアドレスを設定します。

    1. 管理コンソールにログインします。

       管理対象ドメインまたはスタンドアロンサーバーの管理コンソールにログインします。

    2. 監理対象ドメインを使用する場合は、適切なプロファイルを選択します。

       右上にある Profiles タブを選択し、次の画面の左上にある Profile メニューから適切なプロファイルを選択します。full プロファイルと full-ha プロファイルのみで messaging サブシステムが有効になります。

    3. ナビゲーションメニューから Messaging 項目を選択します。

       ナビゲーションメニューから Messaging メニュー項目を展開し、Destinations をクリックします。

    4. JMS プロバイダーを表示します。

       JMS プロバイダーのリストが表示されます。デフォルトの設定では、default という名前の 1 つのプロバイダーだけが表示されます。View リンクをクリックして、このプロバイダーの詳細な設定を表示します。

    5. アドレス設定を表示します。

       Addressing タブをクリックします。Add ボタンをクリックして新しいパターンを追加するか、名前をクリックし、次に Edit ボタンをクリックすることにより、既存のパターンを編集します。

    6. オプションを設定します。

       新しいパターンを追加する場合、Pattern フィールドは address-setting 要素の match パラメーターを参照します。また、Dead Letter Address、Expiry Address、Redelivery Delay、および Max Delivery Attempts を編集することもできます。他のオプションは、管理 CLI を使用して設定する必要があります。