Author: ron.sigal(a)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
Show replies by date