[jboss-remoting-commits] JBoss Remoting SVN: r4027 - remoting3/trunk/http-urlconnection/src/main/java/org/jboss/cx/remoting/http/urlconnection.

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

Author: david.lloyd at jboss.com
Date: 2008-04-19 00:38:03 -0400 (Sat, 19 Apr 2008)
New Revision: 4027

Modified:
   remoting3/trunk/http-urlconnection/src/main/java/org/jboss/cx/remoting/http/urlconnection/AbstractHttpUrlChannel.java
Log:
Fix an unfinished refactor

Modified: remoting3/trunk/http-urlconnection/src/main/java/org/jboss/cx/remoting/http/urlconnection/AbstractHttpUrlChannel.java
===================================================================
--- remoting3/trunk/http-urlconnection/src/main/java/org/jboss/cx/remoting/http/urlconnection/AbstractHttpUrlChannel.java	2008-04-19 04:24:59 UTC (rev 4026)
+++ remoting3/trunk/http-urlconnection/src/main/java/org/jboss/cx/remoting/http/urlconnection/AbstractHttpUrlChannel.java	2008-04-19 04:38:03 UTC (rev 4027)
@@ -19,6 +19,7 @@
 import org.jboss.cx.remoting.util.AbstractOutputStreamByteMessageOutput;
 import org.jboss.cx.remoting.util.IoUtil;
 import org.jboss.cx.remoting.util.NamingThreadFactory;
+import org.jboss.cx.remoting.util.InputStreamByteMessageInput;
 
 /**
  *
@@ -178,7 +179,7 @@
                     }
                     final InputStream inputStream = httpConnection.getInputStream();
                     try {
-                        channelContext.processInboundMessage(INIT_ME);
+                        channelContext.processInboundMessage(new InputStreamByteMessageInput(inputStream, -1));
                     } finally {
                         IoUtil.closeSafely(inputStream);
                     }