server/filtermanager/FilterManager.java

//---PACKAGE DECLARATION---
package uk.ac.ukc.iscream.filtermanager;

//---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: FilterManager.java,v 1.8 2000/11/23 01:44:59 tdb1 Exp $
 */
class FilterManager {

//---FINAL ATTRIBUTES---

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