X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=support%2Fgeneral%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fgeneral%2FThreadSpecificProxyFactory.java;h=5cf23cea73c0d30ad04b6df6b5e7841d266b51c9;hb=5848627da8ebebff9b1a840f70d6f4292323b9b2;hp=00856b100e4e1b8cd47db3813aa67ad0e7db3238;hpb=634eacbd658fcc8b587cee0d814cb67983d7ab5b;p=utils

diff --git a/support/general/src/main/java/org/wamblee/general/ThreadSpecificProxyFactory.java b/support/general/src/main/java/org/wamblee/general/ThreadSpecificProxyFactory.java
index 00856b10..5cf23cea 100644
--- a/support/general/src/main/java/org/wamblee/general/ThreadSpecificProxyFactory.java
+++ b/support/general/src/main/java/org/wamblee/general/ThreadSpecificProxyFactory.java
@@ -24,7 +24,8 @@ import java.lang.reflect.Proxy;
  * Thread-specific proxy is used to create implementations of interfaces that
  * delegate to a thread-specific implementation of the service.
  * 
- * It is used for instance to pass a transaction scoped entity manager around.
+ * It can be used for instance to create a contextual reference to an entity manager 
+ * that delegates to a thread-specific instance. 
  * 
  * The {@link #set(Object)} method sets the current service instance for the current thread. 
  * The {@link #get()} method gets the current service instance for the current thread. 
@@ -53,8 +54,9 @@ public class ThreadSpecificProxyFactory<T> {
         }
     }
 
-    private ThreadLocal<T> svc = new ThreadLocal<T>();
+    private ThreadLocal<T> svc;
     private Class clazz;
+    private T proxy; 
 
     /**
      * Constructs the factory.
@@ -67,7 +69,9 @@ public class ThreadSpecificProxyFactory<T> {
             throw new IllegalArgumentException("Class " + aClass.getName() +
                 " is not an interface");
         }
+        svc = new ThreadLocal<T>();
         clazz = aClass;
+        proxy = createProxy(); 
     }
 
     /**
@@ -97,15 +101,19 @@ public class ThreadSpecificProxyFactory<T> {
      * @return Proxy.
      */
     public T getProxy() {
+        return proxy;
+    }
+
+    private T createProxy() {
         InvocationHandler handler = new ThreadSpecificInvocationHandler();
         Class proxyClass = Proxy.getProxyClass(clazz.getClassLoader(),
             new Class[] { clazz });
-        T proxy;
+        T proxyObj;
         try {
-            proxy = (T) proxyClass.getConstructor(
+            proxyObj = (T) proxyClass.getConstructor(
                 new Class[] { InvocationHandler.class }).newInstance(
                 new Object[] { handler });
-            return proxy;
+            return proxyObj;
         } catch (Exception e) {
             throw new RuntimeException("Could not create proxy for " +
                 clazz.getName(), e);