/Users/nah/Documents/code/cast/src/java/cast/server/ComponentServer.java

Go to the documentation of this file.

package cast.server;

import java.io.File;
import java.net.MalformedURLException;
import java.util.Properties;

import org.apache.log4j.PropertyConfigurator;

import Ice.Application;
import Ice.Communicator;
import Ice.Identity;
import Ice.ObjectAdapter;
import Ice.SignalPolicy;
import cast.cdl.CASTRELEASESTRING;
import cast.cdl.JAVASERVERPORT;
import cast.cdl.LOGGINGENVVAR;
import cast.cdl.LOGGINGPROPERTIESFILE;
import cast.core.logging.ComponentLayout;
import cast.core.logging.ComponentLogger;
import cast.core.logging.LogAdditions;

public class ComponentServer extends Application {

        static {
                initLogging();
        }

        private static void initLogging() {

                // get the file specified by the env var
                if (configureFromEnvironment()) {
                        return;
                } else if (configureFromCWD()) {
                        return;

                } else if (configureFromHome()) {
                        return;
                } else {
                        configureDefault();
                }
        }

        private static void configureDefault() {
                Properties prop = new Properties();
                prop.put("log4j.rootLogger", "INFO, stdout");
                prop.put("log4j.appender.stdout", "org.apache.log4j.ConsoleAppender");
                prop.put("log4j.appender.stdout.layout",
                                ComponentLayout.class.getName());
                PropertyConfigurator.configure(prop);
        }

        private static boolean configureFromEnvironment() {
                String propertiesFileString = System.getenv(LOGGINGENVVAR.value);
                if (propertiesFileString != null) {
                        return configureFromFile(propertiesFileString);
                }
                return false;
        }

        private static boolean configureFromCWD() {
                String propertiesFileString = "./" + LOGGINGPROPERTIESFILE.value;
                return configureFromFile(propertiesFileString);
        }

        private static boolean configureFromHome() {
                String propertiesFileString = System.getProperty("user.home") + "/."
                                + LOGGINGPROPERTIESFILE.value;
                return configureFromFile(propertiesFileString);
        }

        private static boolean configureFromFile(String _filename) {
                try {

                        File propertiesFile = new File(_filename);
                        if (propertiesFile.exists()) {
                                // logger.debug("Using cwd log4j properties: " + _filename);
                                PropertyConfigurator.configure(propertiesFile.toURI().toURL());
                                return true;
                        } else {
                                // System.out.println("failed to use log4j properties: " +
                                // propertiesFile);
                                // logger.warn("Cannot find log4j propoerties file specified by $"
                                // + LOGGINGENVVAR.value + ": " + _filename);
                        }
                } catch (MalformedURLException e) {
                        // logger.warn("Configuration failed with log4j propoerties file: "
                        // + _filename, e);
                }
                return false;
        }

        private ComponentLogger m_logger;
        private LogAdditions m_logAddy;

        public ComponentServer() {
                m_logger = ComponentLogger
                                .getLogger("cast.server.java.ComponentServer");
                m_logAddy = new LogAdditions("cast.server.java.ComponentServer", "");
        }

        public ComponentServer(SignalPolicy _signalPolicy) {
                super(_signalPolicy);
        }

        private void info(Object _o) {
                m_logger.info(_o, m_logAddy);
        }

//      private void debug(Object _o) {
//              m_logger.debug(_o, m_logAddy);
//      }
//
//      private void trace(Object _o) {
//              m_logger.trace(_o, m_logAddy);
//      }

        
        /*
         * (non-Javadoc)
         * 
         * @see Ice.Application#run(java.lang.String[])
         */
        @Override
        public int run(String[] arg0) {

                info("Java server: \"" + CASTRELEASESTRING.value + "\"");

                Communicator ic = communicator();
                ObjectAdapter adapter = ic.createObjectAdapterWithEndpoints(
                                "ComponentServer1", "default -p " + JAVASERVERPORT.value);

                Identity id = new Identity("ComponentFactory", "ComponentFactory");
                adapter.add(new CASTComponentFactory(), id);

                Identity manid = new Identity("comp.man",
                                CASTComponentManager.class.getCanonicalName());
                adapter.add(new CASTComponentManager(), manid);

                // adapter.addServantLocator(new cast.server.ComponentLocator(), "");
                adapter.activate();
                adapter.waitForDeactivate();
                return 0;
        }

        public static void main(String[] args) {
                ComponentServer app = new ComponentServer();
                int status = app.main("cast.server.ComponentServer", args);
                System.exit(status);
        }
}

---