import java.io.IOException;
import java.net.MalformedURLException;
import java.util.Hashtable;

import javax.management.Attribute;
import javax.management.MBeanServerConnection;
import javax.management.MalformedObjectNameException;
import javax.management.ObjectName;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;
import javax.naming.Context;

public class EditWLSMBeans {
   private static MBeanServerConnection connection;
   private static JMXConnector connector;
   private static final ObjectName service;

   // クラス内で使用できるように
   // EditServiceMBean のオブジェクト名を初期化する
   static {
      try {
        service = new ObjectName(
           "com.bea:Name=EditService,Type=weblogic.management.mbeanservers.
            edit.EditServiceMBean");
      } catch (MalformedObjectNameException e) {
         throw new AssertionError(e.getMessage());
      }
   }

   /**
   * ----------------------------------------------------------
   * 編集セッションを開始するメソッド
   * 注意 : MBean を編集する主な手順を示すために、エラー処理は 
   *       最小限になっている。ユーザのコードでは、例外を捕捉
   *       して処理するロジックを含める必要がある
   * ----------------------------------------------------------
   */

   /*
   * 編集 MBean サーバへの接続を初期化する
   */
   public static void initConnection(String hostname, String portString,
      String username, String password) throws IOException,
      MalformedURLException {

      String protocol = "t3";
      Integer portInteger = Integer.valueOf(portString);
      int port = portInteger.intValue();
      String jndiroot = "/jndi/";
      String mserver = "weblogic.management.mbeanservers.edit";

      JMXServiceURL serviceURL = new JMXServiceURL(protocol, hostname, port,
      jndiroot + mserver);

      Hashtable h = new Hashtable();
      h.put(Context.SECURITY_PRINCIPAL, username);
      h.put(Context.SECURITY_CREDENTIALS, password);
      h.put(JMXConnectorFactory.PROTOCOL_PROVIDER_PACKAGES,
         "weblogic.management.remote");
         connector = JMXConnectorFactory.connect(serviceURL, h);
         connection = connector.getMBeanServerConnection();
   }

   /**
   * 編集セッションを開始する
   */
   public ObjectName startEditSession() throws Exception {
      // ConfigurationManagerMBean のオブジェクト名を取得する
      ObjectName cfgMgr = (ObjectName) connection.getAttribute(service,
         "ConfigurationManager");

      // MBeanServerConnection に
      // ConfigurationManager.startEdit(int waitTime int timeout)
      // を呼び出すように指示する。startEdit オペレーションは
      // DomainMBean へのハンドルを返す。それが編集階層のルートになる
      ObjectName domainConfigRoot = (ObjectName) 
         connection.invoke(cfgMgr,"startEdit", 
         new Object[] { new Integer(60000),
         new Integer(120000) }, new String[] { "java.lang.Integer",
         "java.lang.Integer" });
      if (domainConfigRoot == null) {
         // ロックを取得できなかった場合
         throw new Exception("Somebody else is editing already");
      }
      return domainConfigRoot;

   /**
   * ----------------------------------------------------------
   * MBean 属性を変更するメソッド
   * ----------------------------------------------------------
   */

   /**
   * DomainMBean の ConsoleContextPath 属性を変更する
   */
   public void editConsoleContextPath(ObjectName cfgRoot) throws Exception {
      // 呼び出し側メソッドは DomainMBean のオブジェクト名を渡す。
      // このメソッドで必要なのは DomainMBean の属性値の設定のみ
      // 
      Attribute adminport = new Attribute("ConsoleContextPath", new String(
         "secureConsoleContext"));
      connection.setAttribute(cfgRoot, adminport);
      System.out.println("Changed the Admin Console context path to " +
         "secureConsoleContext");
   }

   /**
   * ----------------------------------------------------------
   * 編集をアクティブ化するメソッド
   * ----------------------------------------------------------
   */
   public ObjectName activate() throws Exception {
      // ConfigurationManagerMBean のオブジェクト名を取得する
      ObjectName cfgMgr = (ObjectName) connection.getAttribute(service,
         "ConfigurationManager");
      // MBeanServerConnection に ConfigurationManager.activate(long timeout)
      // を呼び出すように指示する。
      // activate オペレーションは ActivationTaskMBean を返す。
      // ActivationTaskMBean を使用して、ドメインでの変更のアクティブ化の
      // 進行状況を追跡できる
      ObjectName task = (ObjectName) connection.invoke(cfgMgr, "activate",
         new Object[] { new Long(120000) }, new String[] { "java.lang.Long" });
      return task;
   }

   public static void main(String[] args) throws Exception {
      String hostname = args[0];
      String portString = args[1];
      String username = args[2];
      String password = args[3];

      EditWLSMBeans ewb = new EditWLSMBeans();

      // MBean サーバとの接続を初期化する
      initConnection(hostname, portString, username, password);

      // コンフィグレーション マネージャのオブジェクト名を取得する
      ObjectName cfgMgr = (ObjectName) connection.getAttribute(service,
         "ConfigurationManager");

      // セッションを開始する
      ObjectName cfgRoot = ewb.startEditSession();
      // サーバ ログ MBean を編集する
      ewb.editConsoleContextPath(cfgRoot);

      // 保存してアクティブ化する
      connection.invoke(cfgMgr, "save", null, null);
      ewb.activate();

      // MBean サーバとの接続を閉じる
      connector.close();
   }
}

try {
   // 接続を初期化して編集セッションを開始する
...
   ObjectName domainConfigRoot = (ObjectName) connection.invoke(cfgMgr,
      "startEdit", 
      new Object[] { new Integer(30000), new Integer(300000) },
      new String[] { “java.lang.Integer”, “java.lang.Integer” });

   // ドメインを変更する
   ...
   // 変更を保存する
    connection.invoke(cfgMgr, "save", null, null);

} catch (MBeanException e) {
   Exception targetException = e.getTargetException();
   if (targetException instanceof EditTimedOutException) {
      // ロックを取得できなかった。ユーザに通知する
      ...
      throw new MyAppCouldNotStartEditException(e);
   }
   if (targetException instanceof NotEditorException) {
      ...
      throw new MyAppEditSessionFailed(e);
   }
   if (targetException instanceof ValidationException) {
      ...
      try {
        connection.invoke(cfgMgr, "stopEdit", null, null);
      // ここでのラップされた NotEditorException は、保留中の
      // コンフィグレーション MBean 階層でロックを失ったことを表す。
      // ただし、ここでは変更を破棄してロックを解放しようとしているので、
      // この例外が送出されてもエラー状態ではなく、
      // 無視することができる
      } catch (MBeanException e) {
         Exception targetException = e.getTargetException();
         if (targetException instanceof NotEditorException) {
            // 無視する
         }
      }
      throw new MyAppEditChangesInvalid(e);
   }
   else {
   throw MBeanException (e);
   }
}

// 変更は保存されている。ここではその変更をアクティブ化する
try {
   // 変更をアクティブ化する
   ActivationTaskMBean task = (ObjectName) connection.invoke(cfgMgr,
      "activate",
      new Object[] { new Long(60000) }, 
      new String[] { "java.lang.Long" });

   // すべてが処理され、終了するのみ
   String status = (String) connection.getAttribute(task, "State");
   if (status.equals(“4”))
   return;

   // アクティブ化エラーがある場合は、ActivationTaskMBean.getError
   // を使用してエラーに関する情報を取得する
   failure = connection.getAttribute(task, "Error");

// ラップされた NotEditorException を捕捉した場合は、編集セッションが終了したか、
// 管理者によって取り消されたために、変更はアクティブ化されていない。
// ラップされた例外を送出する
} catch (MBeanException e) {
   Exception targetException = e.getTargetException();
   if (targetException instanceof NotEditorException) {
      ...
      throw new MyAppEditSessionFailed(e);
   }
}

// クラスがこれ以降の行を実行するのは、保存された変更のアクティブ化が
// 失敗した場合

// 省略可能 : アクティブ化に失敗した場合、保存されている変更を取り消すことができる。
// 取り消さない場合は、次にだれかが変更をアクティブ化するときに、
// 保存されている変更もアクティブ化される
// try {
//     {
//      connection.invoke(cfgMgr, "undoUnactivatedChanges", null, null);
// catch(MBeanException e) {
//   Exception targetException = e.getTargetException();
//   if (targetException instanceof NotEditorException) {
//      ...
//      throw new MyAppEditSessionFailed(e);
//   }
// }

// 編集セッションを停止する
try {
   connection.invoke(cfgMgr, "stopEdit", null, null);
   // アクティブ化が失敗して、変更を破棄してもよい場合は、
   // 元のタイムアウト期間が経過するのを待つ必要はない。
   // 編集セッションを直ちに停止して、
   // ラップされている NotEditorException を無視できる
} catch (MBeanException e) {
   Exception targetException = e.getTargetException();
   if (targetException instanceof NotEditorException) {
      // 無視する
   }
}
...
// アクティブ化失敗の原因となったエラーに関する情報を出力する
// 
throw new MyAppEditSessionFailed(connection.getAttribute(task, "Error"));