openamf/src/java/org/openamf/invoker SpringBeanInvoker.java,NONE,1.1

Update of /cvsroot/openamf/openamf/src/java/org/openamf/invoker
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv27984/src/java/org/openamf/invoker

Added Files:
	SpringBeanInvoker.java 
Log Message:
invoker for use with the Spring Framework (www.springframework.org)


--- NEW FILE: SpringBeanInvoker.java ---
/*
 * www.openamf.org
 *
 * Distributable under LGPL license.
 * See terms of license at gnu.org.
 */
package org.openamf.invoker;

import java.util.List;
import java.util.ArrayList;
import java.util.Collections;

import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;

import javax.servlet.ServletContext;
import javax.servlet.http.HttpServletRequest;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import org.openamf.ServiceRequest;
import org.openamf.invoker.ServiceInvoker;
import org.openamf.invoker.ServiceInvocationException;
import org.openamf.invoker.RankedMethod;

import org.springframework.web.context.support.WebApplicationContextUtils;
import org.springframework.web.context.WebApplicationContext;

/**
 * @author Andrew Barnes <[email protected]>
 * @author Tom McGee <[email protected]>
 * @version $Revision: 1.1 $, $Date: 2004/09/17 05:01:46 $
 */
public class SpringBeanInvoker extends ServiceInvoker {

	private static Log log = LogFactory.getLog(SpringBeanInvoker.class);
	private WebApplicationContext context;

	public SpringBeanInvoker(
		ServiceRequest request,
		HttpServletRequest servletRequest,
		ServletContext servletContext) {
		super(request, servletRequest, servletContext);
		this.context =
			WebApplicationContextUtils.getWebApplicationContext(
				this.getServletContext());
	}

	public Object invokeService() throws ServiceInvocationException {
		Class serviceClass = null;
		Object service = null;
		Object serviceResult = null;
		try {
			service = this.getPersistentServiceObject();
			if (service == null) {
				service =
					this.context.getBean(this.getRequest().getServiceName());
			}
			serviceClass = service.getClass();
			serviceResult =
				invokeServiceMethod(
					service,
					serviceClass,
					this.getRequest().getServiceMethodName(),
					this.getRequest().getParameters());
			this.setPersistentServiceObject(service);
		} catch (InvocationTargetException e) {
			throw new ServiceInvocationException(
				request,
				e.getTargetException());
		} catch (Exception e) {
			throw new ServiceInvocationException(request, e);
		}
		return serviceResult;
	}

	protected Object invokeServiceMethod(
		Object service,
		Class serviceClass,
		String methodName,
		List parameters)
		throws
			SecurityException,
			NoSuchMethodException,
			IllegalAccessException,
			IllegalArgumentException,
			InvocationTargetException {
		RankedMethod serviceMethod =
			getServiceMethod(serviceClass, methodName, parameters);
		return serviceMethod.invoke(service);
	}

	private RankedMethod getServiceMethod(
		Class serviceClass,
		String methodName,
		List parameters)
		throws SecurityException, NoSuchMethodException {

		RankedMethod serviceMethod = null;
		Method[] methods = serviceClass.getMethods();
		List rankedMethods = new ArrayList(methods.length);
		for (int i = 0; i < methods.length; i++) {
			Method method = methods[i];
			RankedMethod rankedMethod =
				new RankedMethod(method, methodName, parameters);
			if (rankedMethod.isInvokable()) {
				rankedMethods.add(rankedMethod);
			}
		}
		if (rankedMethods.size() > 0) {
			Collections.sort(rankedMethods);
			RankedMethod topRankedMethod = (RankedMethod) rankedMethods.get(0);
			serviceMethod = topRankedMethod;
		}
		if (serviceMethod == null) {
			String errorDesc =
				serviceClass + "." + methodName + "(" + parameters + ")";
			throw new NoSuchMethodException(errorDesc);
		}
		return serviceMethod;
	}

	public boolean getPersistService() {
		return true;
	}

	public String getPersistentServiceName() {
		return this.getRequest().getServiceName();
	}

	public boolean supports(ServiceRequest request) {
		boolean supports = false;
		try {
			context.getBean(this.getRequest().getServiceName());
			supports = true;
		} catch (Exception e) {
			if (log.isDebugEnabled()) {
				log.debug(
					this.getClass().getName()
						+ " does not support service request");
			}
		}
		return supports;
	}

}



-------------------------------------------------------
This SF.Net email is sponsored by: YOU BE THE JUDGE. Be one of 170
Project Admins to receive an Apple iPod Mini FREE for your judgement on
who ports your project to Linux PPC the best. Sponsored by IBM.
Deadline: Sept. 24. Go here: http://sf.net/ppc_contest.php