登録メッセージと登録解除メッセージを作成する

XML メッセージを生成するヘルパークラスの作成が終了したところで、次は createRegistrationString メソッドの実装を記述します。このメソッドは、registerCallbacks メソッドによって呼び出されます (詳細は、「コールバックの登録と登録解除を行う」)。

createRegistrationString は、CallbackReg オブジェクトを構築し、その登録タイプとポートを設定します。続いて、createRegistrationString は、createAllEvent、createMembershipEvent、createRgEvent、および createREvent ヘルパーメソッドを使用して各種のイベントを構築します。各イベントは、CallbackReg オブジェクトが作成されたあとでこのオブジェクトに追加されます。最後に、createRegistrationString は CallbackReg オブジェクト上で convertToXml メソッドを呼び出し、String 形式の XML メッセージを取得します。

regs メンバー変数は、ユーザーがアプリケーションに指定するコマンド行引数を格納します。5 つ目以降の引数は、アプリケーションが登録を行うイベントを指定します。4 つ目の引数は登録のタイプを指定しますが、この例では無視されています。付録 G CrnpClient.java アプリケーションに挙げられている完全なコードでは、この 4 つ目の引数の使用方法も示されています。

1. 上記のロジックを実装する Java コードを作成します。

   private String createRegistrationString() throws Exception
   {
           CallbackReg cbReg = new CallbackReg();
           cbReg.setPort("" + localPort);
   
           cbReg.setRegType(CallbackReg.ADD_CLIENT);
   
           // add the events
           for (int i = 4; i < regs.length; i++) {
                   if (regs[i].equals("M")) {
                           cbReg.addRegEvent(createMembershipEvent());
                   } else if (regs[i].equals("A")) {
                           cbReg.addRegEvent(createAllEvent());
                   } else if (regs[i].substring(0,2).equals("RG")) {
                           cbReg.addRegEvent(createRgEvent(regs[i].substring(3)));
                   } else if (regs[i].substring(0,1).equals("R")) {
                           cbReg.addRegEvent(createREvent(regs[i].substring(2))); 
                   }
           }
   
           String xmlStr = cbReg.convertToXml();
           return (xmlStr);
   }
   
   private Event createAllEvent()
   {
           Event allEvent = new Event();
           allEvent.setClass("EC_Cluster");
           return (allEvent);
   }
   
   private Event createMembershipEvent()
   {
           Event membershipEvent = new Event();
           membershipEvent.setClass("EC_Cluster");
           membershipEvent.setSubclass("ESC_cluster_membership");
           return (membershipEvent);
   }
   
   private Event createRgEvent(String rgname)
   {
           Event rgStateEvent = new Event();
           rgStateEvent.setClass("EC_Cluster");
           rgStateEvent.setSubclass("ESC_cluster_rg_state");
   
           NVPair rgNvpair = new NVPair();
           rgNvpair.setName("rg_name");
           rgNvpair.setValue(rgname);
           rgStateEvent.addNvpair(rgNvpair);
   
           return (rgStateEvent);
   }
   
   private Event createREvent(String rname)
   {
           Event rStateEvent = new Event();
           rStateEvent.setClass("EC_Cluster");
           rStateEvent.setSubclass("ESC_cluster_r_state");
   
           NVPair rNvpair = new NVPair();
           rNvpair.setName("r_name");
           rNvpair.setValue(rname);
           rStateEvent.addNvpair(rNvpair);
   
           return (rStateEvent);
   }

2. 登録解除文字列を作成します。

   イベントを指定する必要がない分、登録解除文字列の作成は登録文字列の作成よりも簡単です。

   private String createUnregistrationString() throws Exception
   {
           CallbackReg cbReg = new CallbackReg();
           cbReg.setPort("" + localPort);
           cbReg.setRegType(CallbackReg.REMOVE_CLIENT);
           String xmlStr = cbReg.convertToXml();
           return (xmlStr);
   }