[jboss-svn-commits] JBL Code SVN: r29085 - in labs/jbossesb/trunk/product/rosetta: tests/src/org/jboss/soa/esb/actions/routing/http and 1 other directory.

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

Author: mageshbk at jboss.com
Date: 2009-08-26 16:32:46 -0400 (Wed, 26 Aug 2009)
New Revision: 29085

Modified:
   labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/actions/routing/http/HttpRouter.java
   labs/jbossesb/trunk/product/rosetta/tests/src/org/jboss/soa/esb/actions/routing/http/HttpRouterUnitTest.java
Log:
[JBESB-2797] HttpRouter fire java.lang.IllegalArgumentException if the Status Code is 304 (Not Modified)

Modified: labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/actions/routing/http/HttpRouter.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/actions/routing/http/HttpRouter.java	2009-08-26 18:28:21 UTC (rev 29084)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/actions/routing/http/HttpRouter.java	2009-08-26 20:32:46 UTC (rev 29085)
@@ -111,7 +111,7 @@
 
                 InputStream resultStream = method.getResponseBodyAsStream();
                 try {
-                    byte[] bytes = StreamUtils.readStream(resultStream);
+                    byte[] bytes = readStream(resultStream);
 
                     if(responseType == ResponseType.STRING) {
                         getPayloadProxy().setPayload(message, new String(bytes, method.getResponseCharSet()));
@@ -132,7 +132,15 @@
 
         return message;
     }
-    
+
+    byte[] readStream(final InputStream stream) throws IOException {
+        if (stream != null) {
+            return StreamUtils.readStream(stream);
+        }
+        else
+           return new byte[0];
+    }
+
     void closeStream(final Closeable c) throws IOException {
         if (c != null) {
             c.close();

Modified: labs/jbossesb/trunk/product/rosetta/tests/src/org/jboss/soa/esb/actions/routing/http/HttpRouterUnitTest.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/tests/src/org/jboss/soa/esb/actions/routing/http/HttpRouterUnitTest.java	2009-08-26 18:28:21 UTC (rev 29084)
+++ labs/jbossesb/trunk/product/rosetta/tests/src/org/jboss/soa/esb/actions/routing/http/HttpRouterUnitTest.java	2009-08-26 20:32:46 UTC (rev 29085)
@@ -99,7 +99,26 @@
             fail(e.getMessage());
         }
     }
-    
+
+    @Test
+    public void testRouter_NullBody() throws ConfigurationException, ActionProcessingException
+    {    
+        final ConfigTree tree = new ConfigTree("ValidMappedHeaderList");
+        tree.setAttribute("endpointUrl", "http://foo.bar");
+        tree.setAttribute("method", "post");
+        tree.setAttribute("MappedHeaderList", "SOAPAction, Content-Type, Accept, If-Modified-Since");
+        
+        HttpRouter router = new HttpRouter(tree);
+        try
+        {
+            router.readStream(null);
+        }
+        catch (final IOException e)
+        {
+            fail(e.getMessage());
+        }
+    }
+
     public static junit.framework.Test suite() {
         return new JUnit4TestAdapter(HttpRouterUnitTest.class);
     }