src/org/objectweb/cjdbc/controller/core/shutdown/ControllerShutdownThread.java

説明を見る。

package org.objectweb.cjdbc.controller.core.shutdown;

import java.io.File;
import java.util.ArrayList;

import org.objectweb.cjdbc.common.exceptions.ShutdownException;
import org.objectweb.cjdbc.common.i18n.Translate;
import org.objectweb.cjdbc.controller.core.Controller;
import org.objectweb.cjdbc.controller.core.ControllerConstants;
import org.objectweb.cjdbc.controller.core.ReportManager;
import org.objectweb.cjdbc.controller.core.ControllerServerThread;
import org.objectweb.cjdbc.controller.jmx.MBeanServerManager;
import org.objectweb.cjdbc.controller.virtualdatabase.VirtualDatabase;

public class ControllerShutdownThread extends ShutdownThread
{
  private Controller controller;
  private ReportManager report;
  private boolean    systemExit = true;

  public ControllerShutdownThread(Controller controller, int ilevel)
  {
    super(ilevel, ShutdownThread.CONTROLLER, controller.getName());
    this.controller = controller;
    this.report = controller.getReport();
  }

  public void shutdownImmediate()
  {
    shutdown();
  }

  protected void beforeShutdown()
  {
    if (report !=null && report.isGenerateOnShutdown())
    {
      report.startReport();
    }
  }

  protected void shutdown()
  {
    logger.info("Shutting down controller");
    logger.debug(Translate.get("controller.shutdown.post"));
    if (report !=null && report.isGenerateOnShutdown())
    {
      report.generate();
      logger.info(Translate.get("fatal.report.generated", report
          .getReportLocation()
          + File.separator + ControllerConstants.REPORT_FILE));
    }
    if (systemExit)
      System.exit(0);
  }

  public void shutdownSmart() throws ShutdownException
  {
    shutdownJmxAgent();
    shutdownServerConnectionThread();
    shutdownDatabases(this.getShutdownLevel());
    shutdown();
  }

  public void shutdownFast() throws ShutdownException
  {
    shutdownJmxAgent();
    shutdownServerConnectionThread();
    shutdownDatabases(this.getShutdownLevel());
    shutdown();
  }

  private void shutdownJmxAgent()
  {
    logger.info("Shutting down Jmx Agent");
    try
    {
      if (controller.getJmxEnable())
        MBeanServerManager.setJmxEnabled(false);
    }
    catch (Exception jme)
    {
      logger.error(Translate.get("controller.shutdown.jmx.error",jme.getMessage()),jme);
      //throw new ShutdownException(jme);
    }
  }

  private void shutdownDatabases(int level)
  {
    logger.info("Shutting down databases");
    try
    {
      //Shutdown each virtual database with proper level
      ArrayList listvb = controller.getVirtualDatabases();
      int nbvb = listvb.size();
      for (int i = 0; i < nbvb; i++)
      {
        logger.info("Shutting down database:"+((VirtualDatabase)listvb.get(i)).getName() + " with level:"+level);
        ((VirtualDatabase) listvb.get(i)).shutdown(level);
        logger.info("Database:"+((VirtualDatabase)listvb.get(i)).getName()+" is shutdown");
      }
    }
    catch (Exception e)
    {
      logger.error(Translate.get("controller.shutdown.database.error",e));
    }
  }

  private void shutdownServerConnectionThread() throws ShutdownException
  {
    logger.info("Shutting down Connection thread");
    try
    {
      // Shutdown Server Connections Thread
      ControllerServerThread thread = controller.getConnectionThread();
      if (thread != null && !thread.isShuttingDown())
        thread.shutdown();
    }
    catch (Exception e)
    {
      throw new ShutdownException(e);
    }
  }

  public void setSystemExit(boolean systemExit)
  {
    this.systemExit = systemExit;
  }
}

---