1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.kuali.rice.ksb.messaging;
17
18 import java.lang.reflect.InvocationHandler;
19 import java.lang.reflect.InvocationTargetException;
20 import java.lang.reflect.Method;
21 import java.lang.reflect.Proxy;
22
23 import javax.xml.namespace.QName;
24
25 import org.apache.log4j.Logger;
26 import org.kuali.rice.core.resourceloader.GlobalResourceLoader;
27 import org.kuali.rice.core.util.ExceptionUtils;
28
29
30
31
32
33
34
35
36
37 public class KSBClientProxy implements InvocationHandler {
38
39 private static final Logger LOG = Logger.getLogger(KSBClientProxy.class);
40
41 QName serviceName;
42 Object service;
43
44 @SuppressWarnings("unchecked")
45 public static <T> T newInstance(String serviceQName, Class<T> interfaceClass) throws InstantiationException, IllegalAccessException {
46 return (T)Proxy.newProxyInstance(interfaceClass.getClassLoader(), new Class[] { interfaceClass }, new KSBClientProxy(serviceQName));
47 }
48
49 public KSBClientProxy(String serviceQName){
50 this.serviceName = QName.valueOf(serviceQName);
51 }
52
53 public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
54 if (this.service == null){
55 LOG.info("Getting service using GRL for: " + serviceName);
56 service = GlobalResourceLoader.getService(serviceName);
57 LOG.info("Obtained service using GRL for: " + serviceName);
58 }
59
60 try {
61 return method.invoke(service, args);
62 } catch (InvocationTargetException e) {
63 throw ExceptionUtils.unwrapActualCause(e);
64 }
65
66 }
67
68 }