View Javadoc

1   /*
2    * Copyright 2007-2008 the original author or authors.
3    * 
4    * Licensed under the Apache License, Version 2.0 (the "License");
5    * you may not use this file except in compliance with the License.
6    * You may obtain a copy of the License at
7    * 
8    *      http://www.apache.org/licenses/LICENSE-2.0
9    * 
10   * Unless required by applicable law or agreed to in writing, software
11   * distributed under the License is distributed on an "AS IS" BASIS,
12   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13   * See the License for the specific language governing permissions and
14   * limitations under the License.
15   */
16  
17  package org.gwe.app.daemon;
18  
19  import java.rmi.RemoteException;
20  import java.rmi.registry.LocateRegistry;
21  import java.rmi.registry.Registry;
22  
23  import org.apache.commons.logging.Log;
24  import org.apache.commons.logging.LogFactory;
25  import org.gwe.GWEAppContext;
26  import org.gwe.app.daemon.domain.UserDomain;
27  import org.gwe.persistence.dao.DaemonConfigDescDAO;
28  import org.gwe.persistence.model.DaemonInstallation;
29  import org.gwe.persistence.model.HeadResourceInfo;
30  import org.gwe.persistence.model.OSAppFolder;
31  
32  /**
33   * @author Marco Ruiz
34   * @since Aug 1, 2007
35   */
36  public class DaemonApp {
37  
38  	private static Log log = LogFactory.getLog(DaemonApp.class);
39  
40  	public static final int DEFAULT_RMI_REGISTRY_PORT = 1099;
41  	public static final String DAEMON_APP_MAIN_COMPLETED_MSG = "DAEMON_APP_MAIN_COMPLETED";
42  	public static final String SPRING_DAEMON_CONF = "spring-gwe-daemon.xml";
43  
44  	public static void main(String[] args) {
45  		DaemonBeacon beacon = new DaemonBeacon();
46  		try {
47  			new DaemonApp().executeApp(args[0]);
48  			beacon.setStop(true);
49  			System.out.println("\n" + DAEMON_APP_MAIN_COMPLETED_MSG);
50  		} catch(Exception e) {
51  			log.fatal("Daemon application failed to launch.", e);
52  			System.exit(1);
53  		}
54  	}
55  	
56  	private void executeApp(String installPath) throws Exception {
57  		install(installPath);
58  		
59  		GWEAppContext ctx = new GWEAppContext(DaemonApp.class, installPath, OSAppFolder.WORKSPACE.getRelativeTo(installPath), SPRING_DAEMON_CONF);
60  		DaemonConfigDescDAO configDescDAO = ctx.getBeanOfClass(DaemonConfigDescDAO.class);
61  		final UserDomain domain = ctx.getBeanOfClass(UserDomain.class);
62  		if (configDescDAO.isDatabaseScheduledForCreationOnThisRun())
63  			domain.setupDaemon(configDescDAO.getConfiguration().getHeadResource());
64  		
65  	    verifyRegistryIsAvailable();
66  	    configDescDAO.getConfiguration().getHeadResource().setRegistryPort(DEFAULT_RMI_REGISTRY_PORT);
67  	    DaemonAppStarter appStarter = ctx.getBeanOfClass(DaemonAppStarter.class);
68  		appStarter.registerRMIServerObjects();
69  		appStarter.startServices();
70  		
71  	    // FIXME: FOR TEST PURPOSES ONLY!!!
72  //		new QueueOrderTest(domain);
73      }
74  
75  	private void install(String installPath) throws Exception {
76  		if (new DaemonConfigDescDAO(installPath).isDatabaseScheduledForCreationOnThisRun())
77  			HeadResourceInfo.createDaemonScriptCommand(installPath, DaemonInstallerApp.class, -1).runLocally();
78      }
79  	
80  	private void install2(String installPath) {
81  	    // Create system directories
82  		new DaemonInstallation(installPath).createDirectories();
83      }
84  	
85  	private void verifyRegistryIsAvailable() throws DaemonAppException {
86  		int port = DEFAULT_RMI_REGISTRY_PORT;
87  		try {
88  			LocateRegistry.createRegistry(port);
89  			return;
90  		} catch (Exception e) {
91  			try {
92  				Registry registry = LocateRegistry.getRegistry();
93  				return;
94  			} catch (RemoteException e1) {
95  			}
96  		}
97  		throw new DaemonAppException("Could not locate/create RMI registry at port " + port);
98  	}
99  	
100 	class DaemonAppException extends Exception {
101 		private static final String MSG_PREFFIX = "Fatal exception while launching daemon. ";
102 		
103 		public DaemonAppException(String msg) { this(msg, null); }
104 		public DaemonAppException(String msg, Exception e) {
105 			super(MSG_PREFFIX + msg, e);
106 			log.fatal(MSG_PREFFIX + msg);
107 		}
108 	}
109 }
110