User: juha
Date: 00/10/29 09:11:50
Modified: src/main/org/jboss/spydermq SpyderMQService.java
Log:
SpyderMQ enabled by default.
Small tweaks to the SpyderMQService.
Revision Changes Path
1.4 +22 -18 jboss/src/main/org/jboss/spydermq/SpyderMQService.java
Index: SpyderMQService.java
===================================================================
RCS file:
/products/cvs/ejboss/jboss/src/main/org/jboss/spydermq/SpyderMQService.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- SpyderMQService.java 2000/08/25 02:38:45 1.3
+++ SpyderMQService.java 2000/10/29 17:11:50 1.4
@@ -21,12 +21,14 @@
import org.jboss.util.ServiceMBeanSupport;
/**
- * <description>
* JMX MBean implementation for SpyderMQ.
*
- * @see <related>
+ * @see SpyderMQ subproject
+ *
* @author Vincent Sheffer ([EMAIL PROTECTED])
- * @version $Revision: 1.3 $
+ * @author <a href="mailto:[EMAIL PROTECTED]">Juha Lindfors</a>
+ *
+ * @version $Revision: 1.4 $
*/
public class SpyderMQService
extends ServiceMBeanSupport
@@ -57,32 +59,29 @@
throws Exception {
if (spyderMQServer == null) {
final Log log = this.log;
- try {
- Class [] spyderMQArgsClasses = null;
- Method startMethod = null;
- Object [] spyderMQArgs = null;
-
+
+ try {
log.log("Testing if SpyderMQ is present....");
try {
- spyderMQServer =
Class.forName("org.spydermq.server.StartServer").newInstance();
+ spyderMQServer =
Thread.currentThread().getContextClassLoader().loadClass("org.spydermq.server.StartServer").newInstance();
log.log("OK");
}catch(Exception e) {
log.log("failed");
- log.log("SpyderMQ wasn't found. Be sure to have your CLASSPATH
correctly set");
+ log.log("SpyderMQ wasn't found:");
+ log.debug(e.getMessage());
return;
}
- spyderMQArgsClasses = new Class[1];
- spyderMQArgsClasses[0] = mBeanServer.getClass();
- startMethod = spyderMQServer.getClass().getMethod("start",
-
spyderMQArgsClasses);
+ Class[] spyderMQArgsClasses = { MBeanServer.class };
+ Object[] spyderMQArgs = { mBeanServer };
- spyderMQArgs = new Object[1];
- spyderMQArgs[0] = mBeanServer;
+ Method startMethod = spyderMQServer.getClass().getMethod("start",
+
spyderMQArgsClasses);
Logger.log("Starting SpyderMQ...");
startMethod.invoke(spyderMQServer, spyderMQArgs);
- } catch (Exception e) {
+ }
+ catch (Exception e) {
log.error("SpyderMQ failed");
log.exception(e);
}
@@ -100,7 +99,12 @@
stopMethod = this.spyderMQServer.getClass().getMethod("stop",
spyderMQArgsClasses);
spyderMQArgs = new Object[0];
- stopMethod.invoke(spyderMQServer, spyderMQArgs);
+
+ // [FIXME] jpl
+ // This causes some error messages on the console so
+ // disabled for now
+
+ //stopMethod.invoke(spyderMQServer, spyderMQArgs);
this.spyderMQServer = null;
} catch (Exception e) {
log.error("SpyderMQ failed");
