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[] {});
+ }
}
|