src/org/objectweb/cjdbc/console/text/module/MonitorConsole.java

説明を見る。

package org.objectweb.cjdbc.console.text.module;

import java.util.Iterator;

import org.objectweb.cjdbc.common.i18n.ConsoleTranslate;
import org.objectweb.cjdbc.console.text.Console;
import org.objectweb.cjdbc.console.text.commands.monitor.AbstractMonitorCommand;
import org.objectweb.cjdbc.console.text.commands.monitor.ChangeTarget;
import org.objectweb.cjdbc.console.text.commands.monitor.ShowBackends;
import org.objectweb.cjdbc.console.text.commands.monitor.ShowCache;
import org.objectweb.cjdbc.console.text.commands.monitor.ShowCacheStats;
import org.objectweb.cjdbc.console.text.commands.monitor.ShowController;
import org.objectweb.cjdbc.console.text.commands.monitor.ShowDatabases;
import org.objectweb.cjdbc.console.text.commands.monitor.ShowRecoveryLog;
import org.objectweb.cjdbc.console.text.commands.monitor.ShowScheduler;
import org.objectweb.cjdbc.console.text.commands.monitor.ShowStats;

public class MonitorConsole extends AbstractConsoleModule
{

  private String currentTarget;

  public String getCurrentTarget()
  {
    return currentTarget;
  }

  public void setCurrentTarget(String currentTarget)
  {
    this.currentTarget = currentTarget;
    Object o;
    Iterator it = commands.iterator();
    while (it.hasNext())
    {
      o = it.next();
      if (o instanceof AbstractMonitorCommand)
      {
        ((AbstractMonitorCommand) o).setCurrentTarget(currentTarget);
      }
    }
  }

  public MonitorConsole(Console console)
  {
    super(console);
  }

  public String getDescriptionString()
  {
    return "Monitoring";
  }

  public String getPromptString()
  {
    return "Monitoring:" + currentTarget;
  }

  protected void loadCommands()
  {
    commands.add(new ChangeTarget(this));
    commands.add(new ShowBackends(this));
    commands.add(new ShowCache(this));
    commands.add(new ShowCacheStats(this));
    commands.add(new ShowController(this));
    commands.add(new ShowDatabases(this));
    commands.add(new ShowScheduler(this));
    commands.add(new ShowStats(this));
    commands.add(new ShowRecoveryLog(this));
  }

  public void login(String[] params)
  {
    String command = (params.length > 0 && params[0] != null) ? params[0] : "";
    if (command.equals("") == false)
    {
      try
      {
        new ChangeTarget(this).execute(params[0]);
      }
      catch (Exception e)
      {
        console.printError(e.getMessage(), e);
      }
    }
    else
    {
      console.printError(ConsoleTranslate.get("module.database.invalid", ""));
      quit = true;
    }
  }
}

---