server/filtermanager/FilterManager.java

//---PACKAGE DECLARATION---

//---IMPORTS---
import uk.ac.ukc.iscream.core.*;
import uk.ac.ukc.iscream.filter.*;
import org.omg.CORBA.*;
import org.omg.CosNaming.*;

/**
 * A FilterManager
 *
 * @author  $Author: tdb1 $
 * @version $Id: FilterManagerMain.java,v 1.3 2000/11/21 23:37:45 tdb1 Exp $
 */
class FilterManager {

//---FINAL ATTRIBUTES---

    /**
     * The current CVS revision of this class
     */
    public static final String REVISION = "$Revision: 1.3 $";
    
//---STATIC METHODS---

    public static void main(String[] args) {
        System.setProperty("org.omg.CORBA.ORBClass","jacorb.orb.ORB");
        System.setProperty("org.omg.CORBA.ORBSingletonClass","jacorb.orb.ORBSingleton");
        
        // can't have a real toString() :)
        String toString = "FilterManager(" + REVISION.substring(11, REVISION.length() - 2) + ")";
        
        try {        
            ORB orb = ORB.init(args, null);
            
            // something to hold objects
            org.omg.CORBA.Object objRef = null;    
              
            // get a hook to the name service
            objRef = orb.resolve_initial_references("NameService");
            NamingContextExt ncRef = NamingContextExtHelper.narrow(objRef);
                
            // get a ref to the Configurator & the Logger
            objRef = ncRef.resolve(ncRef.to_name("iscream.ConfigurationManager"));
            ConfigurationManager configManager = ConfigurationManagerHelper.narrow(objRef);
            objRef = ncRef.resolve(ncRef.to_name("iscream.Logger"));
            Logger logger = LoggerHelper.narrow(objRef);
            
            logger.write(toString, Logger.SYSINIT, "coming up");
            
            // create the servant
            //FilterManagerServant servant = new FilterManagerServant(logger);
            
            // register the servant with the name service
            //objRef = poa.servant_to_reference(servant);
            //ncRef.bind(ncRef.to_name("iscream.FilterManager"), objRef);
            
            // start the POA off
            //poa.the_POAManager().activate();
            
            // get the config
            Configuration myConfig = configManager.getConfiguration("FilterManager");
            
            // some place holders for the configuration
            int port = 0;
  
            // did we?
            if (myConfig == null) {
                System.out.println("Failed: is it there?, can you read it?");
                System.exit(1);
            } else {
              
                // get the property
                try {
                    port = new Integer(myConfig.getProperty("FilterManager.listenPort")).intValue();
                } catch (org.omg.CORBA.MARSHAL e) {
                    System.out.println("Caught org.omg.CORBA.MARSHAL, must be a null we got back");
                    System.exit(1);
                }
            }
            logger.write(toString, Logger.SYSMSG, "configured");
            logger.write(toString, Logger.SYSINIT, "starting listener");
            
            HostListener hostListener = new HostListener(logger, configManager, port, ncRef);
            hostListener.start();
            
            logger.write(toString, Logger.SYSINIT, "started");
            
        } catch (Exception e) {
            System.err.println("FILTER MANAGER ERROR: " + e);
            e.printStackTrace(System.out);
        }
    }

//---CONSTRUCTORS---

//---PUBLIC METHODS---

//---PRIVATE METHODS---

//---ACCESSOR/MUTATOR METHODS---

//---ATTRIBUTES---

//---STATIC ATTRIBUTES---

}            
Revision:	1.8
Committed:	Thu Nov 23 01:44:59 2000 UTC (23 years, 5 months ago) by tdb
Branch:	MAIN
Changes since 1.7:	+10 -15 lines
Log Message:	The main method for the FilterManager.
#	User	Rev	Content
1	tdb	1.1	//---PACKAGE DECLARATION---
2
3			//---IMPORTS---
4			import uk.ac.ukc.iscream.core.*;
5			import uk.ac.ukc.iscream.filter.*;
6			import org.omg.CORBA.*;
7			import org.omg.CosNaming.*;
8
9			/**
10			* A FilterManager
11			*
12	tdb	1.8	* @author $Author: tdb1 $
13			* @version $Id: FilterManagerMain.java,v 1.3 2000/11/21 23:37:45 tdb1 Exp $
14	tdb	1.1	*/
15			class FilterManager {
16
17			//---FINAL ATTRIBUTES---
18
19			/**
20			* The current CVS revision of this class
21			*/
22	tdb	1.8	public static final String REVISION = "$Revision: 1.3 $";
23	tdb	1.1
24			//---STATIC METHODS---
25
26			public static void main(String[] args) {
27	tdb	1.2	System.setProperty("org.omg.CORBA.ORBClass","jacorb.orb.ORB");
28			System.setProperty("org.omg.CORBA.ORBSingletonClass","jacorb.orb.ORBSingleton");
29	tdb	1.1
30			// can't have a real toString() :)
31			String toString = "FilterManager(" + REVISION.substring(11, REVISION.length() - 2) + ")";
32
33			try {
34			ORB orb = ORB.init(args, null);
35
36			// something to hold objects
37			org.omg.CORBA.Object objRef = null;
38
39			// get a hook to the name service
40			objRef = orb.resolve_initial_references("NameService");
41			NamingContextExt ncRef = NamingContextExtHelper.narrow(objRef);
42
43			// get a ref to the Configurator & the Logger
44	tdb	1.4	objRef = ncRef.resolve(ncRef.to_name("iscream.ConfigurationManager"));
45			ConfigurationManager configManager = ConfigurationManagerHelper.narrow(objRef);
46	tdb	1.1	objRef = ncRef.resolve(ncRef.to_name("iscream.Logger"));
47			Logger logger = LoggerHelper.narrow(objRef);
48
49	tdb	1.3	logger.write(toString, Logger.SYSINIT, "coming up");
50	tdb	1.1
51	tdb	1.8	// create the servant
52			//FilterManagerServant servant = new FilterManagerServant(logger);
53	tdb	1.1
54			// register the servant with the name service
55	tdb	1.8	//objRef = poa.servant_to_reference(servant);
56	tdb	1.1	//ncRef.bind(ncRef.to_name("iscream.FilterManager"), objRef);
57
58			// start the POA off
59	tdb	1.8	//poa.the_POAManager().activate();
60	tdb	1.1
61			// get the config
62	ajm	1.6	Configuration myConfig = configManager.getConfiguration("FilterManager");
63	tdb	1.1
64			// some place holders for the configuration
65			int port = 0;
66
67			// did we?
68			if (myConfig == null) {
69			System.out.println("Failed: is it there?, can you read it?");
70			System.exit(1);
71			} else {
72
73			// get the property
74			try {
75	ajm	1.6	port = new Integer(myConfig.getProperty("FilterManager.listenPort")).intValue();
76	tdb	1.1	} catch (org.omg.CORBA.MARSHAL e) {
77			System.out.println("Caught org.omg.CORBA.MARSHAL, must be a null we got back");
78			System.exit(1);
79			}
80			}
81	tdb	1.8	logger.write(toString, Logger.SYSMSG, "configured");
82	tdb	1.3	logger.write(toString, Logger.SYSINIT, "starting listener");
83	tdb	1.1
84	tdb	1.8	HostListener hostListener = new HostListener(logger, configManager, port, ncRef);
85			hostListener.start();
86	tdb	1.1
87	tdb	1.3	logger.write(toString, Logger.SYSINIT, "started");
88	tdb	1.1
89			} catch (Exception e) {
90			System.err.println("FILTER MANAGER ERROR: " + e);
91			e.printStackTrace(System.out);
92			}
93			}
94
95			//---CONSTRUCTORS---
96
97			//---PUBLIC METHODS---
98
99			//---PRIVATE METHODS---
100
101			//---ACCESSOR/MUTATOR METHODS---
102
103			//---ATTRIBUTES---
104
105			//---STATIC ATTRIBUTES---
106
107			}