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.17 by ajm, Fri Feb 23 17:12:40 2001 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.*;
7 < import uk.ac.ukc.iscream.filter.*;
6 < import org.omg.CORBA.*;
7 < import org.omg.CosNaming.*;
8 < import org.omg.PortableServer.*;
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");
35 > //---CONSTRUCTORS---
36 >
37 > //---PUBLIC METHODS---
38 >
39 >    /**
40 >     * This method starts the FilterManager
41 >     */
42 >     public void start() throws ComponentStartException {
43 >        // get references to key objects
44 >        _refman = ReferenceManager.getInstance();
45 >        _logger = ReferenceManager.getInstance().getLogger();
46          
47 <        // can't have a real toString() :)
32 <        String toString = "FilterManager(" + REVISION.substring(11, REVISION.length() - 2) + ")";
47 >        _logger.write(toString(), Logger.SYSINIT, "coming up");
48          
49 <        try {        
50 <            ORB orb = ORB.init(args, null);
51 <            
52 <            // something to hold objects
53 <            org.omg.CORBA.Object objRef = null;    
54 <            
55 <            // get the Root POA
56 <            objRef = orb.resolve_initial_references("RootPOA");
57 <            POA poa = POAHelper.narrow(objRef);
58 <              
59 <            // get a hook to the name service
60 <            objRef = orb.resolve_initial_references("NameService");
61 <            NamingContextExt ncRef = NamingContextExtHelper.narrow(objRef);
47 <                
48 <            // get a ref to the Configurator & the Logger
49 <            objRef = ncRef.resolve(ncRef.to_name("iscream.ConfigurationManager"));
50 <            ConfigurationManager configManager = ConfigurationManagerHelper.narrow(objRef);
51 <            objRef = ncRef.resolve(ncRef.to_name("iscream.Logger"));
52 <            Logger logger = LoggerHelper.narrow(objRef);
53 <            
54 <            logger.write(toString, Logger.SYSINIT, "coming up");
55 <            
56 <            // create the filterManagerRef to our servant
57 <            //filterManagerRef = new FilterManagerServant;
58 <            
59 <            // register the servant with the name service
60 <            //objRef = poa.servant_to_reference(filterManagerRef);
61 <            //ncRef.bind(ncRef.to_name("iscream.FilterManager"), objRef);
62 <            
63 <            // start the POA off
64 <            poa.the_POAManager().activate();
65 <            
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?");
75 <                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 <                }
49 >        // configuration variable we require
50 >        int listenPort = 0;
51 >        
52 >        Configuration config = _refman.getCM().getConfiguration("FilterManager");
53 >        if (config == null) {
54 >            throw new ComponentStartException("Unable to obtain configuration for component");
55 >        }
56 >        else {
57 >            try {
58 >                // get the configuration properties we need
59 >                listenPort = Integer.parseInt(config.getProperty("FilterManager.listenPort"));
60 >            } catch (org.omg.CORBA.MARSHAL e) {
61 >                throw new ComponentStartException("Unable to obtain requried configuration property for component");
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 +        // startup a thread to listen for hosts
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  
102 //---PUBLIC METHODS---
103
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;
112 +
113 +    /**
114 +     * A reference to the reference manager in use
115 +     */
116 +    private ReferenceManager _refman;
117  
118   //---STATIC ATTRIBUTES---
119  

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines