David Ostrovsky
2014-02-26 a3de33e71a22268105714e01d09c1c2e28bfe2c3
src/main/java/com/gitblit/manager/ServicesManager.java
@@ -42,6 +42,8 @@
import com.gitblit.models.RepositoryModel;
import com.gitblit.models.UserModel;
import com.gitblit.service.FederationPullService;
import com.gitblit.transport.ssh.SshDaemon;
import com.gitblit.utils.IdGenerator;
import com.gitblit.utils.StringUtils;
import com.gitblit.utils.TimeUtils;
@@ -67,6 +69,8 @@
   private GitDaemon gitDaemon;
   private SshDaemon sshDaemon;
   public ServicesManager(IGitblit gitblit) {
      this.settings = gitblit.getSettings();
      this.gitblit = gitblit;
@@ -77,6 +81,7 @@
      configureFederation();
      configureFanout();
      configureGitDaemon();
      configureSshDaemon();
      return this;
   }
@@ -89,6 +94,9 @@
      }
      if (gitDaemon != null) {
         gitDaemon.stop();
      }
      if (sshDaemon != null) {
         sshDaemon.stop();
      }
      return this;
   }
@@ -138,6 +146,20 @@
      }
   }
   protected void configureSshDaemon() {
      int port = settings.getInteger(Keys.git.sshPort, 0);
      String bindInterface = settings.getString(Keys.git.sshBindInterface, "localhost");
      if (port > 0) {
         try {
            sshDaemon = new SshDaemon(gitblit, new IdGenerator());
            sshDaemon.start();
         } catch (IOException e) {
            sshDaemon = null;
            logger.error(MessageFormat.format("Failed to start SSH daemon on {0}:{1,number,0}", bindInterface, port), e);
         }
      }
   }
   protected void configureFanout() {
      // startup Fanout PubSub service
      if (settings.getInteger(Keys.fanout.port, 0) > 0) {