[jboss-remoting-commits] JBoss Remoting SVN: r6347 - remoting2/branches/2.x/src/main/org/jboss/remoting.

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

Author: ron.sigal at jboss.com
Date: 2011-04-29 17:08:16 -0400 (Fri, 29 Apr 2011)
New Revision: 6347

Modified:
   remoting2/branches/2.x/src/main/org/jboss/remoting/Client.java
Log:
JBREM-1288: invoke() with InputStream checks for LocalClientInvoker.

Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/Client.java
===================================================================
--- remoting2/branches/2.x/src/main/org/jboss/remoting/Client.java	2011-04-28 03:05:35 UTC (rev 6346)
+++ remoting2/branches/2.x/src/main/org/jboss/remoting/Client.java	2011-04-29 21:08:16 UTC (rev 6347)
@@ -1756,7 +1756,15 @@
     */
    public Object invoke(InputStream inputStream, Object param) throws Throwable
    {
-      StreamServer streamServer = new StreamServer(inputStream);
+      StreamServer streamServer = null;
+      if (invoker instanceof LocalClientInvoker)
+      {
+         streamServer = new StreamServer(inputStream, "local");
+      }
+      else
+      {
+         streamServer = new StreamServer(inputStream);
+      }
       String locator = streamServer.getInvokerLocator();
 
       // now call on target server and pass locator for stream callbacks