/*  * Copyright 2004-2005 OpenSymphony  *  * Licensed under the Apache License, Version 2.0 (the "License"); you may not  * use this file except in compliance with the License. You may obtain a copy  * of the License at  *  *   http://www.apache.org/licenses/LICENSE-2.0  *    * Unless required by applicable law or agreed to in writing, software  * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT  * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the  * License for the specific language governing permissions and limitations  * under the License. *  *//* * Previously Copyright (c) 2001-2004 James House */package org.quartz.jobs.ee.jmx;import java.util.LinkedList;import java.util.StringTokenizer;import javax.management.MBeanServer;import javax.management.MBeanServerFactory;import javax.management.ObjectName;import org.apache.commons.logging.Log;import org.apache.commons.logging.LogFactory;import org.quartz.Job;import org.quartz.JobExecutionContext;import org.quartz.JobExecutionException;/** * Generic JMX invoker Job.  It supports any number or type of parameters * to the JMX bean.<p> *  * The required parameters are as follows (case doesn't matter):<p> * <dl> * <dt><strong>JMX_OBJECTNAME</strong> * <dd>This is the fully qualifed name of the object (ie in JBoss to lookup * the log4j jmx bean you would specify "jboss.system:type=Log4jService,service=Logging" * <dt><strong>JMX_METHOD</strong> * <dd>This is the method to invoke on the specified JMX Bean. (ie in JBoss to * change the log level you would specify "setLoggerLevel" * <dt><strong>JMX_PARAMDEFS</strong> * <dd>This is a definition of the parameters to be passed to the specified method * and their corresponding java types.  Each parameter definition is comma seperated * and has the following parts: <type>:<name>.  Type is the java type for the parameter.   * The following types are supported:<p> * <b>i</b> - is for int<p> * <b>l</b> - is for long<p> * <b>f</b> - is for float<p> * <b>d</b> - is for double<p> * <b>s</b> - is for String<p> * <b>b</b> - is for boolean<p> * For ilfdb use lower for native type and upper for object wrapper. The name portion * of the definition is the name of the parameter holding the string value. (ie * s:fname,s:lname would require 2 parameters of the name fname and lname and * would be passed in that order to the method. *  * @author James Nelson (jmn@provident-solutions.com) -- Provident Solutions LLC *  */public class JMXInvokerJob implements Job {	public void execute(JobExecutionContext context) throws JobExecutionException {		try {			Object[] params=null;			String[] types=null;			String objName = null;			String objMethod = null;			String[] keys = context.getJobDetail().getJobDataMap().getKeys();			for (int i = 0; i < keys.length; i++) {				String value = context.getJobDetail().getJobDataMap().getString(keys[i]);				if ("JMX_OBJECTNAME".equalsIgnoreCase(keys[i])) {					objName = value;				} else if ("JMX_METHOD".equalsIgnoreCase(keys[i])) {					objMethod = value;				} else if("JMX_PARAMDEFS".equalsIgnoreCase(keys[i])) {					String[] paramdefs=split(value, ",");					params=new Object[paramdefs.length];					types=new String[paramdefs.length];					for(int k=0;k<paramdefs.length;k++) {						String parts[]=  split(paramdefs[k], ":");						if(parts.length<2)							throw new Exception("Invalid parameter definition: required parts missing "+paramdefs[k]);						switch(parts[0].charAt(0)) {							case 'i':								params[k]=new Integer(context.getJobDetail().getJobDataMap().getString(parts[1]));								types[k]=Integer.TYPE.getName();								break;							case 'I':								params[k]=new Integer(context.getJobDetail().getJobDataMap().getString(parts[1]));								types[k]=Integer.class.getName();								break;							case 'l':								params[k]=new Long(context.getJobDetail().getJobDataMap().getString(parts[1]));								types[k]=Long.TYPE.getName();								break;							case 'L':								params[k]=new Long(context.getJobDetail().getJobDataMap().getString(parts[1]));								types[k]=Long.class.getName();								break;							case 'f':								params[k]=new Float(context.getJobDetail().getJobDataMap().getString(parts[1]));								types[k]=Float.TYPE.getName();								break;							case 'F':								params[k]=new Float(context.getJobDetail().getJobDataMap().getString(parts[1]));								types[k]=Float.class.getName();								break;							case 'd':								params[k]=new Double(context.getJobDetail().getJobDataMap().getString(parts[1]));								types[k]=Double.TYPE.getName();								break;							case 'D':								params[k]=new Double(context.getJobDetail().getJobDataMap().getString(parts[1]));								types[k]=Double.class.getName();								break;							case 's':								params[k]=new String(context.getJobDetail().getJobDataMap().getString(parts[1]));								types[k]=String.class.getName();								break;							case 'b':								params[k]=new Boolean(context.getJobDetail().getJobDataMap().getString(parts[1]));								types[k]=Boolean.TYPE.getName();								break;							case 'B':								params[k]=new Boolean(context.getJobDetail().getJobDataMap().getString(parts[1]));								types[k]=Boolean.class.getName();								break;						}					}				}			}						if(objName==null || objMethod==null) 				throw new Exception("Required parameters missing");						invoke(objName, objMethod, params, types);		} catch (Exception e) {			String m = "Caught a " + e.getClass().getName() + " exception : " + e.getMessage();			getLog().error(m, e);			throw new JobExecutionException(m, e, false);		}	}    private String[] split(String str, String splitStr) // Same as String.split(.) in JDK 1.4  {    LinkedList l = new LinkedList();        StringTokenizer strTok = new StringTokenizer(str, splitStr);    while(strTok.hasMoreTokens()) {      String tok = strTok.nextToken();      l.add(tok);    }        return (String[])l.toArray(new String[l.size()]);  }	private void invoke(String objectName, String method, Object[] params, String[] types) throws Exception {		MBeanServer server = (MBeanServer) MBeanServerFactory.findMBeanServer(null).get(0);		ObjectName mbean = new ObjectName(objectName);		if (server == null)			throw new Exception("Can't find mbean server");		getLog().info("invoking " + method);		server.invoke(mbean, method, params, types);	}	private static Log getLog() {		return LogFactory.getLog(JMXInvokerJob.class);	}}