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.4 by tdb, Mon Nov 20 18:55:24 2000 UTC vs.
Revision 1.12 by ajm, Tue Dec 12 19:17:02 2000 UTC

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

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines