1 files changed, 9 insertions, 4 deletions
diff --git a/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/src/main/java/org/apache/tuscany/sca/binding/jsonrpc/provider/JSONRPCClientInvoker.java b/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/src/main/java/org/apache/tuscany/sca/binding/jsonrpc/provider/JSONRPCClientInvoker.java
index 2b0859c416..3b2d2b707d 100644
--- a/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/src/main/java/org/apache/tuscany/sca/binding/jsonrpc/provider/JSONRPCClientInvoker.java
+++ b/sca-java-2.x/trunk/modules/binding-jsonrpc-runtime/src/main/java/org/apache/tuscany/sca/binding/jsonrpc/provider/JSONRPCClientInvoker.java
@@ -26,9 +26,9 @@ import org.apache.tuscany.sca.assembly.EndpointReference;
 import org.apache.tuscany.sca.binding.jsonrpc.JSONRPCBinding;
 import org.apache.tuscany.sca.interfacedef.Operation;
 import org.apache.tuscany.sca.interfacedef.java.JavaOperation;
+import org.apache.tuscany.sca.invocation.DataExchangeSemantics;
 import org.apache.tuscany.sca.invocation.Invoker;
 import org.apache.tuscany.sca.invocation.Message;
-import org.jabsorb.client.Client;
 import org.jabsorb.client.Session;
 import org.jabsorb.client.TransportRegistry;
 
@@ -37,7 +37,7 @@ import org.jabsorb.client.TransportRegistry;
  * 
  * @version $Rev$ $Date$
  */
-public class JSONRPCClientInvoker implements Invoker {
+public class JSONRPCClientInvoker implements Invoker, DataExchangeSemantics {
     private EndpointReference endpointReference;
     private Operation operation;
     private Method method;
@@ -52,7 +52,7 @@ public class JSONRPCClientInvoker implements Invoker {
 
     public Message invoke(Message msg) {
         Session session = TransportRegistry.i().createSession(uri);
-        Client client = new Client(session);
+        JSONRPCClient client = new JSONRPCClient(session);
         Object proxy = client.openProxy("", method.getDeclaringClass());
 
         try {
@@ -66,5 +66,10 @@ public class JSONRPCClientInvoker implements Invoker {
         }
         return msg;
     }
-    
+
+    @Override
+    public boolean allowsPassByReference() {
+        return true;
+    }
+
 }