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

Comparing projects/cms/source/server/uk/org/iscream/cms/server/client/ClientMain.java (file contents):
Revision 1.7 by tdb, Tue Feb 27 01:01:33 2001 UTC vs.
Revision 1.14 by tdb, Wed Mar 14 01:54:24 2001 UTC

# Line 39 | Line 39 | public class ClientMain implements Component {
39       */
40      public void start() throws ComponentStartException {
41          // get references to key objects
42 <        _refman = ReferenceManager.getInstance();
43 <        _logger = ReferenceManager.getInstance().getLogger();
42 >        _logger = _refman.getLogger();
43  
44          _logger.write(toString(), Logger.SYSINIT, "coming up");
45              
# Line 62 | Line 61 | public class ClientMain implements Component {
61                
62          _logger.write(toString(), Logger.SYSINIT, "configured");
63          
64 +        // setup the queues, this must be done before both managers are setup
65 +        String queueName;
66          // setup a Queue for the servant -> monitor manager
67 <        Queue queue = new Queue();
67 <        // startup a monitor on this queue
68 <        String queueName = NAME + " ServantToMonMan";
69 <        queue.startMonitor(queueMonitorInterval*1000, queueName);
67 >        _monitorQueue = new Queue();
68          
69 +        // setup a Queue for the monitors -> alert manager
70 +        _alerterQueue = new Queue();
71 +        
72 +        
73 +        
74          // setup the servant and connect
75          _logger.write(toString(), Logger.SYSINIT, "starting servant and connecting");          
76          try {
77 <            ClientServant ref = new ClientServant(queue);
77 >            ClientServant ref = new ClientServant(_monitorQueue);
78              org.omg.CORBA.Object objRef = _refman.getRootPOA().servant_to_reference(ref);
79              Client client = ClientHelper.narrow(objRef);
80              
# Line 80 | Line 83 | public class ClientMain implements Component {
83              CorbaClientListener listener = CorbaClientListenerHelper.narrow(objRef);
84              
85              _logger.write(toString(), Logger.SYSINIT, "connecting");
86 <            CorbaControlHandler handler = listener.connect(client);
86 >            CorbaControlHandler handler = listener.connect(client, NAME);
87              handler.startData();
88          }
89          catch(Exception e) {
# Line 90 | Line 93 | public class ClientMain implements Component {
93          }
94          
95          // setup the MonitorManager
96 <        MonitorManager monMan = new MonitorManager(queue);
96 >        MonitorManager monMan = MonitorManager.getInstance();
97 >        monMan.start();
98          
99 +        // setup the AlerterManager
100 +        AlerterManager alertMan = AlerterManager.getInstance();
101 +        alertMan.start();
102 +      
103          _logger.write(toString(), Logger.SYSINIT, "started");
104          
105      }
106 <
106 >    
107      /**
108 +     * Does a dependency check. Used mainly at startup to
109 +     * see if the required dependencies (components) are up
110 +     * and running.
111 +     *
112 +     * @return a boolean value, true if the depdencies are satisfied
113 +     */
114 +    public boolean depCheck() {
115 +        try {
116 +            org.omg.CORBA.Object obj;
117 +            // first check the ConfigurationManager is alive
118 +            obj = _refman.getCORBARef("iscream.ConfigurationManager");
119 +            // then get some info on the CLI
120 +            ConfigurationProxy cp = ConfigurationProxy.getInstance();
121 +            String cli = cp.getProperty("RootFilter", "RootFilter.realtimeInterfaceName");
122 +            // finally check the CLI is alive
123 +            obj = _refman.getCORBARef("iscream.ClientInterface." + cli);
124 +        } catch(ComponentCORBAException e) {
125 +            System.err.println(toString() + ": Dependency Failure: "+e);
126 +            return false;
127 +        } catch(PropertyNotFoundException e) {
128 +            System.err.println(toString() + ": Unable to obtain configuration: "+e);
129 +            return false;
130 +        }
131 +        // dependency check suceeded
132 +        return true;
133 +    }
134 +    
135 +    /**
136       * Overrides the {@link java.lang.Object#toString() Object.toString()}
137       * method to provide clean logging (every class should have this).
138       *
# Line 127 | Line 163 | public class ClientMain implements Component {
163      /**
164       * A reference to the reference manager in use
165       */
166 <    private ReferenceManager _refman;
166 >    private ReferenceManager _refman = ReferenceManager.getInstance();
167  
168   //---STATIC ATTRIBUTES---
169 +
170 +    /**
171 +     * A queue for the alerter manager
172 +     */
173 +    public static Queue _alerterQueue;
174 +    
175 +    /**
176 +     * A queue for the monitor manager
177 +     */
178 +    public static Queue _monitorQueue;
179  
180   }

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines