SONAR-4898 rename StartServer to App

1 files changed, 157 insertions, 0 deletions

diff --git a/sonar-application/src/main/java/org/sonar/application/App.java b/sonar-application/src/main/java/org/sonar/application/App.java
new file mode 100644
index 00000000000..afd335a06d3
--- /dev/null
+++ b/sonar-application/src/main/java/org/sonar/application/App.java
@@ -0,0 +1,157 @@
+/*
+ * SonarQube, open source software quality management tool.
+ * Copyright (C) 2008-2014 SonarSource
+ * mailto:contact AT sonarsource DOT com
+ *
+ * SonarQube is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ *
+ * SonarQube is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+ */
+package org.sonar.application;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.sonar.process.Monitor;
+import org.sonar.process.Process;
+import org.sonar.process.ProcessMXBean;
+import org.sonar.process.ProcessWrapper;
+
+import javax.annotation.Nullable;
+import javax.management.InstanceAlreadyExistsException;
+import javax.management.MBeanRegistrationException;
+import javax.management.MBeanServer;
+import javax.management.NotCompliantMBeanException;
+
+import java.lang.management.ManagementFactory;
+
+public class App implements ProcessMXBean {
+
+  static final String PROCESS_NAME = "SonarQube";
+
+  private final Installation installation;
+  private Monitor monitor;
+  private ProcessWrapper elasticsearch;
+  private ProcessWrapper server;
+
+  private static Logger LOGGER = LoggerFactory.getLogger(App.class);
+
+  public App(Installation installation) throws Exception {
+    this.installation = installation;
+
+    Thread shutdownHook = new Thread(new Runnable() {
+      @Override
+      public void run() {
+        LOGGER.info("JVM Shutdown start");
+        terminate();
+        LOGGER.info("JVM Shutdown end");
+      }
+    });
+    Runtime.getRuntime().addShutdownHook(shutdownHook);
+
+    MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();
+    try {
+      mbeanServer.registerMBean(this, Process.objectNameFor(PROCESS_NAME));
+    } catch (InstanceAlreadyExistsException e) {
+      throw new IllegalStateException("Process already exists in current JVM", e);
+    } catch (MBeanRegistrationException e) {
+      throw new IllegalStateException("Could not register process as MBean", e);
+    } catch (NotCompliantMBeanException e) {
+      throw new IllegalStateException("Process is not a compliant MBean", e);
+    }
+
+    monitor = new Monitor();
+  }
+
+  public void start() {
+    elasticsearch = new ProcessWrapper("ES")
+      .setWorkDir(installation.homeDir())
+      .setJmxPort(Integer.parseInt(installation.prop(DefaultSettings.ES_JMX_PORT_KEY)))
+      .addJavaOpts(installation.prop(DefaultSettings.ES_JAVA_OPTS_KEY))
+      .addJavaOpts(String.format("-Djava.io.tmpdir=%s", installation.tempDir().getAbsolutePath()))
+      .addJavaOpts(String.format("-D%s=%s", DefaultSettings.PATH_LOGS_KEY, installation.logsDir().getAbsolutePath()))
+      .setClassName("org.sonar.search.ElasticSearch")
+      .setProperties(installation.props().cryptedProperties())
+      .addClasspath(installation.starPath("lib/common"))
+      .addClasspath(installation.starPath("lib/search"))
+      .execute();
+    monitor.registerProcess(elasticsearch);
+
+    server = new ProcessWrapper("SQ")
+      .setWorkDir(installation.homeDir())
+      .setJmxPort(Integer.parseInt(installation.prop(DefaultSettings.WEB_JMX_PORT_KEY)))
+      .addJavaOpts(installation.prop(DefaultSettings.WEB_JAVA_OPTS_KEY))
+      .addJavaOpts(DefaultSettings.WEB_JAVA_OPTS_APPENDED_VAL)
+      .addJavaOpts(String.format("-Djava.io.tmpdir=%s", installation.tempDir().getAbsolutePath()))
+      .addJavaOpts(String.format("-D%s=%s", DefaultSettings.PATH_LOGS_KEY, installation.logsDir().getAbsolutePath()))
+      .setClassName("org.sonar.server.app.ServerProcess")
+      .setProperties(installation.props().cryptedProperties())
+      .addClasspath(installation.starPath("extensions/jdbc-driver/mysql"))
+      .addClasspath(installation.starPath("extensions/jdbc-driver/mssql"))
+      .addClasspath(installation.starPath("extensions/jdbc-driver/oracle"))
+      .addClasspath(installation.starPath("extensions/jdbc-driver/postgresql"))
+      .addClasspath(installation.starPath("lib/common"))
+      .addClasspath(installation.starPath("lib/server"))
+      .execute();
+    monitor.registerProcess(server);
+
+    monitor.start();
+
+    try {
+      try {
+        monitor.join();
+      } catch (InterruptedException e) {
+        LOGGER.info("Monitor interrupted. Shutting down...");
+      }
+    } finally {
+      terminate();
+    }
+  }
+
+  @Override
+  public void terminate() {
+    if (monitor != null) {
+      monitor.interrupt();
+      monitor = null;
+      terminateAndWait(elasticsearch);
+      terminateAndWait(server);
+    }
+
+  }
+
+  private void terminateAndWait(@Nullable ProcessWrapper process) {
+    if (process != null) {
+      process.terminate();
+      try {
+        process.join();
+      } catch (InterruptedException e) {
+        LOGGER.warn("Process '{}' did not gracefully shutdown.", process.getName());
+      }
+    }
+  }
+
+  @Override
+  public boolean isReady() {
+    return monitor.isAlive();
+  }
+
+  @Override
+  public long ping() {
+    return System.currentTimeMillis();
+  }
+
+  public static void main(String[] args) throws Exception {
+    Installation installation = new Installation();
+    new AppLogging().configure(installation);
+    new App(installation).start();
+  }
+}