User: starksm
Date: 01/07/08 14:19:28
Modified: src/main/org/jboss Tag: Branch_2_4 Main.java
Log:
Merge the latest JBossMQ changes into the 2.4 release
Revision Changes Path
No revision
No revision
1.35.2.3 +242 -241 jboss/src/main/org/jboss/Main.java
Index: Main.java
===================================================================
RCS file: /cvsroot/jboss/jboss/src/main/org/jboss/Main.java,v
retrieving revision 1.35.2.2
retrieving revision 1.35.2.3
diff -u -r1.35.2.2 -r1.35.2.3
--- Main.java 2001/06/23 01:26:40 1.35.2.2
+++ Main.java 2001/07/08 21:19:27 1.35.2.3
@@ -1,241 +1,242 @@
-/*
- * JBoss, the OpenSource EJB server
- *
- * Distributable under LGPL license.
- * See terms of license at gnu.org.
- */
-
-package org.jboss;
-
-import java.io.File;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.PrintStream;
-import java.io.BufferedReader;
-import java.io.InputStreamReader;
-import java.io.PrintWriter;
-import java.io.FileWriter;
-import java.net.URL;
-import java.security.*;
-import java.util.*;
-
-import javax.management.*;
-import javax.management.loading.*;
-
-/**
- *
- * @see <related>
- * @author Rickard Öberg ([EMAIL PROTECTED])
- * @author <a href="mailto:[EMAIL PROTECTED]";>Daniel O'Connor</a>.
- * @author [EMAIL PROTECTED]
- * @version $Revision: 1.35.2.2 $
- */
-public class Main
-{
- // Constants -----------------------------------------------------
-
- String versionIdentifier = "2.4 BETA(Rel_2_4_0_6)";
- // Attributes ----------------------------------------------------
-
- // Static --------------------------------------------------------
- public static void main(final String[] args)
- throws Exception
- {
- String cn = "default"; // Default configuration name is "default", i.e. all
conf files are in "/conf/default"
- String patchDir = null;
- // Given conf name?
- if (args.length == 1)
- cn = args[0];
- for(int a = 0; a < args.length; a ++)
- {
- if( args[a].startsWith("-p") )
- patchDir = args[a+1];
- }
- final String confName = cn;
- final String patchDirName = patchDir;
-
- // Load system properties
- URL jbossProps =
Main.class.getClassLoader().getResource(confName+"/jboss.properties");
- InputStream propertiesIn =
Main.class.getClassLoader().getResourceAsStream(confName+"/jboss.properties");
- if ( propertiesIn == null )
- {
- throw new IOException("jboss.properties missing");
- }
-
- System.getProperties().load(propertiesIn);
-
- /* Set a jboss.home property from the location of the Main.class jar
- if the property does not exist.
- */
- if( System.getProperty("jboss.home") == null )
- {
- String path =
Main.class.getProtectionDomain().getCodeSource().getLocation().getFile();
- File runJar = new File(path);
- // Home dir should be the parent of the dir containing run.jar
- File homeDir = new File(runJar.getParent(), "..");
- System.setProperty("jboss.home", homeDir.getCanonicalPath());
- }
- System.out.println("jboss.home = "+System.getProperty("jboss.home"));
-
- // Set the JAAS login config file if not already set
- if( System.getProperty("java.security.auth.login.config") == null )
- {
- URL loginConfig =
Main.class.getClassLoader().getResource(confName+"/auth.conf");
- if( loginConfig != null )
- {
- System.setProperty("java.security.auth.login.config",
loginConfig.toExternalForm());
- System.out.println("Using JAAS LoginConfig:
"+loginConfig.toExternalForm());
- }
- else
- {
- System.out.println("Warning: no auth.conf found in config="+confName);
- }
- }
-
- // Set security
- URL serverPolicy =
Main.class.getClassLoader().getResource(confName+"/server.policy");
-
- if ( serverPolicy == null )
- {
- throw new IOException("server.policy missing");
- }
-
- System.setProperty("java.security.policy", serverPolicy.getFile());
-
- // Set security manager
- // Optional for better performance
- if (System.getProperty("java.security.manager") != null)
-
System.setSecurityManager((SecurityManager)Class.forName(System.getProperty("java.security.manager")).newInstance());
-
- // Start server - Main does not have the proper permissions
- AccessController.doPrivileged(new PrivilegedAction()
- {
- public Object run()
- {
- new Main(confName, patchDirName);
- return null;
- }
- });
- }
-
- // Constructors --------------------------------------------------
- public Main(String confName, String patchDir)
- {
- Date startTime = new Date();
-
- try
- {
- System.out.println("Using configuration \""+confName+"\"");
-
- final PrintStream err = System.err;
-
- com.sun.management.jmx.Trace.parseTraceProperties();
-
- // Give feedback about from where jndi.properties is read
- URL jndiLocation = this.getClass().getResource("/jndi.properties");
- if (jndiLocation instanceof URL) {
- System.out.println("Please make sure the following is intended (check
your CLASSPATH):");
- System.out.println(" jndi.properties is read from "+jndiLocation);
- }
-
- // Create MBeanServer
- final MBeanServer server = MBeanServerFactory.createMBeanServer();
-
- // Add configuration directory to MLet
- URL confDirectory = new
File("../conf/"+confName).getCanonicalFile().toURL();
- URL[] urls = {confDirectory};
- // Add any patch jars to the MLet so they are seen ahead of the JBoss jars
- if( patchDir != null )
- {
- File dir = new File(patchDir);
- ArrayList tmp = new ArrayList();
- File[] jars = dir.listFiles(new java.io.FileFilter()
- {
- public boolean accept(File pathname)
- {
- String name = pathname.getName();
- return name.endsWith(".jar") || name.endsWith(".zip");
- }
- }
- );
- tmp.add(confDirectory);
- for(int j = 0; jars != null && j < jars.length; j ++)
- {
- File jar = jars[j];
- URL u = jar.getCanonicalFile().toURL();
- tmp.add(u);
- }
- urls = new URL[tmp.size()];
- tmp.toArray(urls);
- }
-
- // Create MLet
- MLet mlet = new MLet(urls);
- server.registerMBean(mlet, new ObjectName(server.getDefaultDomain(),
"service", "MLet"));
-
- // Set MLet as classloader for this app
- Thread.currentThread().setContextClassLoader(mlet);
-
- // Load configuration
- URL mletConf = mlet.getResource("jboss.conf");
- Set beans = (Set)mlet.getMBeansFromURL(mletConf);
- Iterator enum = beans.iterator();
- while (enum.hasNext())
- {
- Object obj = enum.next();
- if (obj instanceof RuntimeOperationsException)
-
((RuntimeOperationsException)obj).getTargetException().printStackTrace(err);
- else if (obj instanceof RuntimeErrorException)
- ((RuntimeErrorException)obj).getTargetError().printStackTrace(err);
- else if (obj instanceof MBeanException)
- ((MBeanException)obj).getTargetException().printStackTrace(err);
- else if (obj instanceof RuntimeMBeanException)
-
((RuntimeMBeanException)obj).getTargetException().printStackTrace(err);
- else if (obj instanceof ReflectionException)
- ((ReflectionException)obj).getTargetException().printStackTrace(err);
- else if (obj instanceof Throwable)
- ((Throwable)obj).printStackTrace(err);
- }
-
- // Load configuration
- server.invoke(new ObjectName(":service=Configuration"),
"loadConfiguration", new Object[0], new String[0]);
-
- // Store configuration
- // This way, the config will always contain a complete mirror of what's in
the server
- server.invoke(new ObjectName(":service=Configuration"),
"saveConfiguration", new Object[0] , new String[0]);
-
- // Init and Start MBeans
- server.invoke(new ObjectName(":service=ServiceControl"), "init", new
Object[0] , new String[0]);
- server.invoke(new ObjectName(":service=ServiceControl"), "start", new
Object[0] , new String[0]);
-
- }
- catch (RuntimeOperationsException e)
- {
- System.out.println("Runtime error");
- e.getTargetException().printStackTrace();
- }
- catch (RuntimeErrorException e)
- {
- System.out.println("Runtime error");
- e.getTargetError().printStackTrace();
- }
- catch (MBeanException e)
- {
- e.getTargetException().printStackTrace();
- }
- catch (RuntimeMBeanException e)
- {
- e.getTargetException().printStackTrace();
- }
- catch (Exception e)
- {
- e.printStackTrace();
- }
-
- // Done
- Date stopTime = new Date();
- Date lapsedTime = new Date(stopTime.getTime()-startTime.getTime());
- System.out.println("JBoss "+versionIdentifier+" Started in
"+lapsedTime.getMinutes()+"m:"+lapsedTime.getSeconds()+"s");
- }
-}
-
+/*
+ * JBoss, the OpenSource EJB server
+ *
+ * Distributable under LGPL license.
+ * See terms of license at gnu.org.
+ */
+
+package org.jboss;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.PrintStream;
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.io.PrintWriter;
+import java.io.FileWriter;
+import java.net.URL;
+import java.security.*;
+import java.util.*;
+
+import javax.management.*;
+import javax.management.loading.*;
+
+/**
+ *
+ * @see <related>
+ * @author Rickard Öberg ([EMAIL PROTECTED])
+ * @author <a href="mailto:[EMAIL PROTECTED]";>Daniel O'Connor</a>.
+ * @author [EMAIL PROTECTED]
+ * @version $Revision: 1.35.2.3 $
+ */
+public class Main
+{
+ // Constants -----------------------------------------------------
+
+ String versionIdentifier = "2.4 BETA(Rel_2_4_0_13)";
+ // Attributes ----------------------------------------------------
+
+ // Static --------------------------------------------------------
+ public static void main(final String[] args)
+ throws Exception
+ {
+ Thread.currentThread().setName("JBossMain");
+ String cn = "default"; // Default configuration name is "default", i.e. all
conf files are in "/conf/default"
+ String patchDir = null;
+ // Given conf name?
+ if (args.length == 1)
+ cn = args[0];
+ for(int a = 0; a < args.length; a ++)
+ {
+ if( args[a].startsWith("-p") )
+ patchDir = args[a+1];
+ }
+ final String confName = cn;
+ final String patchDirName = patchDir;
+
+ // Load system properties
+ URL jbossProps =
Main.class.getClassLoader().getResource(confName+"/jboss.properties");
+ InputStream propertiesIn =
Main.class.getClassLoader().getResourceAsStream(confName+"/jboss.properties");
+ if ( propertiesIn == null )
+ {
+ throw new IOException("jboss.properties missing");
+ }
+
+ System.getProperties().load(propertiesIn);
+
+ /* Set a jboss.home property from the location of the Main.class jar
+ if the property does not exist.
+ */
+ if( System.getProperty("jboss.home") == null )
+ {
+ String path =
Main.class.getProtectionDomain().getCodeSource().getLocation().getFile();
+ File runJar = new File(path);
+ // Home dir should be the parent of the dir containing run.jar
+ File homeDir = new File(runJar.getParent(), "..");
+ System.setProperty("jboss.home", homeDir.getCanonicalPath());
+ }
+ System.out.println("jboss.home = "+System.getProperty("jboss.home"));
+
+ // Set the JAAS login config file if not already set
+ if( System.getProperty("java.security.auth.login.config") == null )
+ {
+ URL loginConfig =
Main.class.getClassLoader().getResource(confName+"/auth.conf");
+ if( loginConfig != null )
+ {
+ System.setProperty("java.security.auth.login.config",
loginConfig.toExternalForm());
+ System.out.println("Using JAAS LoginConfig:
"+loginConfig.toExternalForm());
+ }
+ else
+ {
+ System.out.println("Warning: no auth.conf found in config="+confName);
+ }
+ }
+
+ // Set security
+ URL serverPolicy =
Main.class.getClassLoader().getResource(confName+"/server.policy");
+
+ if ( serverPolicy == null )
+ {
+ throw new IOException("server.policy missing");
+ }
+
+ System.setProperty("java.security.policy", serverPolicy.getFile());
+
+ // Set security manager
+ // Optional for better performance
+ if (System.getProperty("java.security.manager") != null)
+
System.setSecurityManager((SecurityManager)Class.forName(System.getProperty("java.security.manager")).newInstance());
+
+ // Start server - Main does not have the proper permissions
+ AccessController.doPrivileged(new PrivilegedAction()
+ {
+ public Object run()
+ {
+ new Main(confName, patchDirName);
+ return null;
+ }
+ });
+ }
+
+ // Constructors --------------------------------------------------
+ public Main(String confName, String patchDir)
+ {
+ Date startTime = new Date();
+
+ try
+ {
+ System.out.println("Using configuration \""+confName+"\"");
+
+ final PrintStream err = System.err;
+
+ com.sun.management.jmx.Trace.parseTraceProperties();
+
+ // Give feedback about from where jndi.properties is read
+ URL jndiLocation = this.getClass().getResource("/jndi.properties");
+ if (jndiLocation instanceof URL) {
+ System.out.println("Please make sure the following is intended (check
your CLASSPATH):");
+ System.out.println(" jndi.properties is read from "+jndiLocation);
+ }
+
+ // Create MBeanServer
+ final MBeanServer server = MBeanServerFactory.createMBeanServer();
+
+ // Add configuration directory to MLet
+ URL confDirectory = new
File("../conf/"+confName).getCanonicalFile().toURL();
+ URL[] urls = {confDirectory};
+ // Add any patch jars to the MLet so they are seen ahead of the JBoss jars
+ if( patchDir != null )
+ {
+ File dir = new File(patchDir);
+ ArrayList tmp = new ArrayList();
+ File[] jars = dir.listFiles(new java.io.FileFilter()
+ {
+ public boolean accept(File pathname)
+ {
+ String name = pathname.getName();
+ return name.endsWith(".jar") || name.endsWith(".zip");
+ }
+ }
+ );
+ tmp.add(confDirectory);
+ for(int j = 0; jars != null && j < jars.length; j ++)
+ {
+ File jar = jars[j];
+ URL u = jar.getCanonicalFile().toURL();
+ tmp.add(u);
+ }
+ urls = new URL[tmp.size()];
+ tmp.toArray(urls);
+ }
+
+ // Create MLet
+ MLet mlet = new MLet(urls);
+ server.registerMBean(mlet, new ObjectName(server.getDefaultDomain(),
"service", "MLet"));
+
+ // Set MLet as classloader for this app
+ Thread.currentThread().setContextClassLoader(mlet);
+
+ // Load configuration
+ URL mletConf = mlet.getResource("jboss.conf");
+ Set beans = (Set)mlet.getMBeansFromURL(mletConf);
+ Iterator enum = beans.iterator();
+ while (enum.hasNext())
+ {
+ Object obj = enum.next();
+ if (obj instanceof RuntimeOperationsException)
+
((RuntimeOperationsException)obj).getTargetException().printStackTrace(err);
+ else if (obj instanceof RuntimeErrorException)
+ ((RuntimeErrorException)obj).getTargetError().printStackTrace(err);
+ else if (obj instanceof MBeanException)
+ ((MBeanException)obj).getTargetException().printStackTrace(err);
+ else if (obj instanceof RuntimeMBeanException)
+
((RuntimeMBeanException)obj).getTargetException().printStackTrace(err);
+ else if (obj instanceof ReflectionException)
+ ((ReflectionException)obj).getTargetException().printStackTrace(err);
+ else if (obj instanceof Throwable)
+ ((Throwable)obj).printStackTrace(err);
+ }
+
+ // Load configuration
+ server.invoke(new ObjectName(":service=Configuration"),
"loadConfiguration", new Object[0], new String[0]);
+
+ // Store configuration
+ // This way, the config will always contain a complete mirror of what's in
the server
+ server.invoke(new ObjectName(":service=Configuration"),
"saveConfiguration", new Object[0] , new String[0]);
+
+ // Init and Start MBeans
+ server.invoke(new ObjectName(":service=ServiceControl"), "init", new
Object[0] , new String[0]);
+ server.invoke(new ObjectName(":service=ServiceControl"), "start", new
Object[0] , new String[0]);
+
+ }
+ catch (RuntimeOperationsException e)
+ {
+ System.out.println("Runtime error");
+ e.getTargetException().printStackTrace();
+ }
+ catch (RuntimeErrorException e)
+ {
+ System.out.println("Runtime error");
+ e.getTargetError().printStackTrace();
+ }
+ catch (MBeanException e)
+ {
+ e.getTargetException().printStackTrace();
+ }
+ catch (RuntimeMBeanException e)
+ {
+ e.getTargetException().printStackTrace();
+ }
+ catch (Exception e)
+ {
+ e.printStackTrace();
+ }
+
+ // Done
+ Date stopTime = new Date();
+ Date lapsedTime = new Date(stopTime.getTime()-startTime.getTime());
+ System.out.println("JBoss "+versionIdentifier+" Started in
"+lapsedTime.getMinutes()+"m:"+lapsedTime.getSeconds()+"s");
+ }
+}
+
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
