[jboss-svn-commits] JBoss Common SVN: r4179 - invokablecontainer/trunk/api/src/main/java/org/jboss/invokable.

[jboss-svn-commits at lists.jboss.org]

Author: david.lloyd at jboss.com
Date: 2010-03-15 17:34:54 -0400 (Mon, 15 Mar 2010)
New Revision: 4179

Modified:
   invokablecontainer/trunk/api/src/main/java/org/jboss/invokable/ProxyInvocationHandler.java
Log:
Proxy invocation handler should probably have a processor too

Modified: invokablecontainer/trunk/api/src/main/java/org/jboss/invokable/ProxyInvocationHandler.java
===================================================================
--- invokablecontainer/trunk/api/src/main/java/org/jboss/invokable/ProxyInvocationHandler.java	2010-03-12 17:19:59 UTC (rev 4178)
+++ invokablecontainer/trunk/api/src/main/java/org/jboss/invokable/ProxyInvocationHandler.java	2010-03-15 21:34:54 UTC (rev 4179)
@@ -38,15 +38,28 @@
 
     private static final long serialVersionUID = -7550306900997519378L;
 
+    /**
+     * The invocation processor to pass the invocation through.
+     *
+     * @serial
+     */
+    private final InvocationProcessor processor;
+    /**
+     * The invocation dispatcher which should handle the invocation.
+     *
+     * @serial
+     */
     private final InvocationDispatcher dispatcher;
 
     /**
      * Construct a new instance.
      *
+     * @param processor
      * @param dispatcher the dispatcher to send invocations to
      */
-    public ProxyInvocationHandler(final InvocationDispatcher dispatcher) {
+    public ProxyInvocationHandler(final InvocationProcessor processor, final InvocationDispatcher dispatcher) {
         this.dispatcher = dispatcher;
+        this.processor = processor;
     }
 
     /**
@@ -60,7 +73,7 @@
      */
     public Object invoke(final Object proxy, final Method method, final Object[] args) throws Throwable {
         try {
-            return dispatcher.dispatch(new Invocation(method, args));
+            return processor.processInvocation(dispatcher, new Invocation(method, args));
         } catch (InvocationException e) {
             throw e.getCause();
         }