ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/filtermanager/FilterManager.java
(Generate patch)

Comparing projects/cms/source/server/uk/org/iscream/cms/server/filtermanager/FilterManager.java (file contents):
Revision 1.9 by tdb, Wed Nov 29 19:19:12 2000 UTC vs.
Revision 1.14 by tdb, Thu Jan 18 23:19:29 2001 UTC

# Line 2 | Line 2
2   package uk.ac.ukc.iscream.filtermanager;
3  
4   //---IMPORTS---
5 + import uk.ac.ukc.iscream.util.*;
6   import uk.ac.ukc.iscream.core.*;
7 < import uk.ac.ukc.iscream.filter.*;
7 < import org.omg.CORBA.*;
8 < import org.omg.CosNaming.*;
7 > import uk.ac.ukc.iscream.componentmanager.*;
8  
9   /**
10 < * A FilterManager
10 > * The FilterManager handles initialisation
11 > * of hosts with the system, allowing hosts to
12 > * gain their configuration and a hook to a Filter
13 > * to talk to.
14   *
15   * @author  $Author$
16   * @version $Id$
17   */
18 < class FilterManager {
18 > public class FilterManager implements Component {
19  
20   //---FINAL ATTRIBUTES---
21  
# Line 22 | Line 24 | class FilterManager {
24       */
25      public static final String REVISION = "$Revision$";
26      
27 +    /**
28 +     * The friendly name for this component, used by
29 +     * all related classes.
30 +     */
31 +    public static final String NAME = "FilterManager";
32 +    
33   //---STATIC METHODS---
34  
35 <    public static void main(String[] args) {
36 <        System.setProperty("org.omg.CORBA.ORBClass","jacorb.orb.ORB");
37 <        System.setProperty("org.omg.CORBA.ORBSingletonClass","jacorb.orb.ORBSingleton");
38 <        
39 <        // can't have a real toString() :)
40 <        String toString = "FilterManager(" + REVISION.substring(11, REVISION.length() - 2) + ")";
41 <        
42 <        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);
35 > //---CONSTRUCTORS---
36 >
37 > //---PUBLIC METHODS---
38 >
39 >    /**
40 >     * This method starts the FilterManager
41 >     */
42 >     public void start() throws ComponentStartException {
43                  
44 <            // get a ref to the Configurator & the Logger
45 <            objRef = ncRef.resolve(ncRef.to_name("iscream.ConfigurationManager"));
46 <            ConfigurationManager configManager = ConfigurationManagerHelper.narrow(objRef);
47 <            objRef = ncRef.resolve(ncRef.to_name("iscream.Logger"));
48 <            Logger logger = LoggerHelper.narrow(objRef);
49 <            
50 <            logger.write(toString, Logger.SYSINIT, "coming up");
51 <            
52 <            // create the servant
53 <            //FilterManagerServant servant = new FilterManagerServant(logger);
54 <            
55 <            // register the servant with the name service
56 <            //objRef = poa.servant_to_reference(servant);
57 <            //ncRef.bind(ncRef.to_name("iscream.FilterManager"), objRef);
58 <            
59 <            // start the POA off
60 <            //poa.the_POAManager().activate();
61 <            
62 <            // get the config
63 <            Configuration myConfig = configManager.getConfiguration("FilterManager");
64 <            
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?");
44 >        _logger.write(toString(), Logger.SYSINIT, "coming up");
45 >        
46 >        // configuration variable we require
47 >        int listenPort = 0;
48 >
49 >        Configuration config = _refman.getCM().getConfiguration("FilterManager");
50 >        if (config == null) {
51 >            System.err.println("CRITICAL:Unable to obtain configuration" +
52 >                               "\n         Advise you check the i-scream log for more information.");
53 >            _logger.write(toString(), Logger.FATAL, "ERROR - unable to obtain configuration");
54 >            System.exit(1);
55 >        } else {
56 >            try {
57 >                listenPort = Integer.parseInt(config.getProperty("FilterManager.listenPort"));
58 >            } catch (org.omg.CORBA.MARSHAL e) {
59 >                System.err.println ("CRITICAL:Unable to obtain required configuration property" +
60 >                                    "\n         Advise you check the i-scream log for more information.");
61 >                _logger.write(toString(), Logger.FATAL, "ERROR - required configuration property not present");
62                  System.exit(1);
72            } else {
73              
74                // get the property
75                try {
76                    port = new Integer(myConfig.getProperty("FilterManager.listenPort")).intValue();
77                } 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                }
63              }
82            logger.write(toString, Logger.SYSMSG, "configured");
83            logger.write(toString, Logger.SYSINIT, "starting listener");
84            
85            HostListener hostListener = new HostListener(logger, configManager, port, ncRef);
86            hostListener.start();
87            
88            logger.write(toString, Logger.SYSINIT, "started");
89            
90        } catch (Exception e) {
91            System.err.println("FILTER MANAGER ERROR: " + e);
92            e.printStackTrace(System.out);
64          }
65 +        
66 +        _logger.write(toString(), Logger.SYSMSG, "configured");
67 +        
68 +        HostListener hostListener = new HostListener(listenPort);
69 +        hostListener.start();
70 +        
71 +        _logger.write(toString(), Logger.SYSINIT, "started");
72      }
73  
74 < //---CONSTRUCTORS---
74 >    /**
75 >     * Overrides the {@link java.lang.Object#toString() Object.toString()}
76 >     * method to provide clean logging (every class should have this).
77 >     *
78 >     * This uses the uk.ac.ukc.iscream.util.NameFormat class
79 >     * to format the toString()
80 >     *
81 >     * @return the name of this class and its CVS revision
82 >     */
83 >    public String toString() {
84 >        return FormatName.getName(
85 >            _name,
86 >            getClass().getName(),
87 >            REVISION);
88 >    }
89  
98 //---PUBLIC METHODS---
99
90   //---PRIVATE METHODS---
91  
92   //---ACCESSOR/MUTATOR METHODS---
93  
94   //---ATTRIBUTES---
95 +
96 +    /**
97 +     * This is the friendly identifier of the
98 +     * component this class is running in.
99 +     * eg, a Filter may be called "filter1",
100 +     * If this class does not have an owning
101 +     * component,  a name from the configuration
102 +     * can be placed here.  This name could also
103 +     * be changed to null for utility classes.
104 +     */
105 +    private String _name = FilterManager.NAME;
106 +
107 +    /**
108 +     * This holds a reference to the
109 +     * system logger that is being used.
110 +     */
111 +    private Logger _logger = ReferenceManager.getInstance().getLogger();
112 +
113 +    /**
114 +     * A reference to the reference manager in use
115 +     */
116 +    private ReferenceManager _refman = ReferenceManager.getInstance();
117  
118   //---STATIC ATTRIBUTES---
119  

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines