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.8 by tdb, Thu Nov 23 01:44:59 2000 UTC vs.
Revision 1.13 by ajm, Tue Dec 12 19:55:45 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.*;
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 21 | Line 23 | class FilterManager {
23       */
24      public static final String REVISION = "$Revision$";
25      
26 +    /**
27 +     * The friendly name for this component, 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 {        
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);
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 servant
52 <            //FilterManagerServant servant = new FilterManagerServant(logger);
53 <            
54 <            // register the servant with the name service
55 <            //objRef = poa.servant_to_reference(servant);
56 <            //ncRef.bind(ncRef.to_name("iscream.FilterManager"), objRef);
57 <            
58 <            // start the POA off
59 <            //poa.the_POAManager().activate();
60 <            
61 <            // get the config
62 <            Configuration myConfig = configManager.getConfiguration("FilterManager");
63 <            
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?");
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);
71            } else {
72              
73                // get the property
74                try {
75                    port = new Integer(myConfig.getProperty("FilterManager.listenPort")).intValue();
76                } 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                }
62              }
81            logger.write(toString, Logger.SYSMSG, "configured");
82            logger.write(toString, Logger.SYSINIT, "starting listener");
83            
84            HostListener hostListener = new HostListener(logger, configManager, port, ncRef);
85            hostListener.start();
86            
87            logger.write(toString, Logger.SYSINIT, "started");
88            
89        } catch (Exception e) {
90            System.err.println("FILTER MANAGER ERROR: " + e);
91            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 >            getClass().getName(),
86 >            REVISION);
87 >    }
88  
97 //---PUBLIC METHODS---
98
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