[jboss-svn-commits] JBL Code SVN: r28934 - in labs/jbossesb/workspace/platform/branches/SOA-4.3.0.GA_CP01_SOA-1441/product/rosetta: tests/src/org/jboss/soa/esb/actions/routing/http and 1 other directory.

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

Author: mputz
Date: 2009-08-14 09:53:02 -0400 (Fri, 14 Aug 2009)
New Revision: 28934

Modified:
   labs/jbossesb/workspace/platform/branches/SOA-4.3.0.GA_CP01_SOA-1441/product/rosetta/src/org/jboss/soa/esb/actions/routing/http/HttpRouter.java
   labs/jbossesb/workspace/platform/branches/SOA-4.3.0.GA_CP01_SOA-1441/product/rosetta/tests/src/org/jboss/soa/esb/actions/routing/http/HttpRouterUnitTest.java
Log:
SOA-1441: One-off patch to fix JBESB-2525/JBESB-2784

Modified: labs/jbossesb/workspace/platform/branches/SOA-4.3.0.GA_CP01_SOA-1441/product/rosetta/src/org/jboss/soa/esb/actions/routing/http/HttpRouter.java
===================================================================
--- labs/jbossesb/workspace/platform/branches/SOA-4.3.0.GA_CP01_SOA-1441/product/rosetta/src/org/jboss/soa/esb/actions/routing/http/HttpRouter.java	2009-08-14 12:10:42 UTC (rev 28933)
+++ labs/jbossesb/workspace/platform/branches/SOA-4.3.0.GA_CP01_SOA-1441/product/rosetta/src/org/jboss/soa/esb/actions/routing/http/HttpRouter.java	2009-08-14 13:53:02 UTC (rev 28934)
@@ -35,6 +35,7 @@
 import org.jboss.soa.esb.message.Message;
 import org.jboss.internal.soa.esb.util.StreamUtils;
 
+import java.io.Closeable;
 import java.io.IOException;
 import java.io.InputStream;
 import java.net.MalformedURLException;
@@ -115,7 +116,7 @@
                 } catch (MessageDeliverException e) {
                     e.printStackTrace();
                 } finally {
-                    resultStream.close();
+                    closeStream(resultStream);
                 }
             } finally {
                 method.releaseConnection();
@@ -127,6 +128,11 @@
         return message;
     }
     
+    void closeStream(final Closeable c) throws IOException {
+        if (c != null) {
+            c.close();
+        }
+    }
     private String[] extractMappedHeaderListConfig() throws ConfigurationException {
         final String mappedHeaders = config.getAttribute("MappedHeaderList");
         if (mappedHeaders != null) {

Modified: labs/jbossesb/workspace/platform/branches/SOA-4.3.0.GA_CP01_SOA-1441/product/rosetta/tests/src/org/jboss/soa/esb/actions/routing/http/HttpRouterUnitTest.java
===================================================================
--- labs/jbossesb/workspace/platform/branches/SOA-4.3.0.GA_CP01_SOA-1441/product/rosetta/tests/src/org/jboss/soa/esb/actions/routing/http/HttpRouterUnitTest.java	2009-08-14 12:10:42 UTC (rev 28933)
+++ labs/jbossesb/workspace/platform/branches/SOA-4.3.0.GA_CP01_SOA-1441/product/rosetta/tests/src/org/jboss/soa/esb/actions/routing/http/HttpRouterUnitTest.java	2009-08-14 13:53:02 UTC (rev 28934)
@@ -22,15 +22,20 @@
 
 package org.jboss.soa.esb.actions.routing.http;
 
+import static org.junit.Assert.*;
 import static org.junit.Assert.assertEquals;
 
+import java.io.IOException;
 import java.util.ArrayList;
 import java.util.List;
 
 import junit.framework.JUnit4TestAdapter;
 
 import org.jboss.soa.esb.ConfigurationException;
+import org.jboss.soa.esb.actions.ActionProcessingException;
 import org.jboss.soa.esb.helpers.ConfigTree;
+import org.jboss.soa.esb.message.Message;
+import org.jboss.soa.esb.message.format.MessageFactory;
 import org.junit.Before;
 import org.junit.Test;
 
@@ -75,6 +80,25 @@
 
         assertEquals(0, headers.size());
     }
+
+    @Test
+    public void testRouter_NullResponse() 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");
+        
+        HttpRouter router = new HttpRouter(tree);
+        try
+        {
+            router.closeStream(null);
+        } 
+        catch (final IOException e)
+        {
+            fail(e.getMessage());
+        }
+    }
     
     public static junit.framework.Test suite() {
         return new JUnit4TestAdapter(HttpRouterUnitTest.class);