[Hyperic-hq-discuss] hq r3732 - in trunk/src/org/hyperic/hq/ha/server: mbean session

[<rm...@hy...>]

Author: rmorgan
Date: 2007-03-13 12:08:24 -0800 (Tue, 13 Mar 2007)
New Revision: 3732
URL: http://svn.hyperic.org/?view=rev&root=Hyperic+HQ&revision=3732

Modified:
   trunk/src/org/hyperic/hq/ha/server/mbean/HAService.java
   trunk/src/org/hyperic/hq/ha/server/session/HAStartupListener.java
Log:
Start Quartz scheduler on all nodes, not just the master. [HQ-569]

Modified: trunk/src/org/hyperic/hq/ha/server/mbean/HAService.java
===================================================================
--- trunk/src/org/hyperic/hq/ha/server/mbean/HAService.java	2007-03-13 11:40:41 UTC (rev 3731)
+++ trunk/src/org/hyperic/hq/ha/server/mbean/HAService.java	2007-03-13 20:08:24 UTC (rev 3732)
@@ -48,7 +48,6 @@
     public void startSingleton() {
         MBeanServer server = MBeanUtil.getMBeanServer();
         try {
-            startScheduler(server);
             startDataPurgeService(server);
             startHeartbeatService(server);
             startAvailCheckService(server);
@@ -64,13 +63,6 @@
         // XXX: shut down services
     }
 
-    private void startScheduler(MBeanServer server)
-        throws Exception
-    {
-        invoke(server, "hyperic.jmx:type=Service,name=Scheduler",
-               "startScheduler");
-    }
-
     private void startDataPurgeService(MBeanServer server)
         throws Exception
     {

Modified: trunk/src/org/hyperic/hq/ha/server/session/HAStartupListener.java
===================================================================
--- trunk/src/org/hyperic/hq/ha/server/session/HAStartupListener.java	2007-03-13 11:40:41 UTC (rev 3731)
+++ trunk/src/org/hyperic/hq/ha/server/session/HAStartupListener.java	2007-03-13 20:08:24 UTC (rev 3732)
@@ -43,6 +43,7 @@
         try {
             _log.info("Starting services");
             startConfigService(server);
+            startScheduler(server);
             startHAService(server);
         } catch (Exception e) {
             _log.error("Unable to start services", e);
@@ -68,4 +69,11 @@
 
         server.invoke(o, "start", new Object[] {}, new String[] {});
     }
+
+    private void startScheduler(MBeanServer server)
+        throws Exception
+    {
+        ObjectName o = new ObjectName("hyperic.jmx:type=Service,name=Scheduler");
+        server.invoke(o, "startScheduler", new Object[] {}, new String[] {});
+    }
 }