svn commit: r682303 - in /synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp: Axis2HttpRequest.java NhttpConstants.java

[ruwan]

Author: ruwan
Date: Mon Aug  4 02:27:20 2008
New Revision: 682303

URL: http://svn.apache.org/viewvc?rev=682303&view=rev
Log:
committing for Saliya, SYNAPSE-392, I assume this will be optimized after 
getting the TempData class out to a new module called synapse-utils...

Modified:
    
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/Axis2HttpRequest.java
    
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/NhttpConstants.java

Modified: 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/Axis2HttpRequest.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/Axis2HttpRequest.java?rev=682303&r1=682302&r2=682303&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/Axis2HttpRequest.java
 (original)
+++ 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/Axis2HttpRequest.java
 Mon Aug  4 02:27:20 2008
@@ -141,8 +141,11 @@
                 ByteArrayOutputStream baos = new ByteArrayOutputStream();
                 messageFormatter.writeTo(msgContext, format, baos, true);
                 BasicHttpEntity entity = new BasicHttpEntity();
-                entity.setContentLength(baos.toByteArray().length);
+                byte[] bytes = baos.toByteArray();
+                msgContext.setProperty(NhttpConstants.SERIALIZED_BYTES, bytes);
+                entity.setContentLength(bytes.length);
                 ((BasicHttpEntityEnclosingRequest) 
httpRequest).setEntity(entity);
+
             }
 
 
@@ -231,7 +234,11 @@
         if (!completed) {
             OutputStream out = new ContentOutputStream(outputBuffer);
             try {
-                messageFormatter.writeTo(msgContext, format, out, false);
+                if (msgContext.isPropertyTrue(NhttpConstants.FORCE_HTTP_1_0)) {
+                    
out.write((byte[])msgContext.getProperty(NhttpConstants.SERIALIZED_BYTES));
+                } else {
+                    messageFormatter.writeTo(msgContext, format, out, false);
+                }        
             } catch (Exception e) {
                 Throwable t = e.getCause();
                 if (t != null && t.getCause() != null && t.getCause() 
instanceof ClosedChannelException) {

Modified: 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/NhttpConstants.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/NhttpConstants.java?rev=682303&r1=682302&r2=682303&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/NhttpConstants.java
 (original)
+++ 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/NhttpConstants.java
 Mon Aug  4 02:27:20 2008
@@ -34,4 +34,5 @@
     public static final String SERVICE_URI_LOCATION = "ServiceURI";
     public static final String EPR_TO_SERVICE_NAME_MAP = "service.epr.map";
     public static final String NON_BLOCKING_TRANSPORT = "NonBlockingTransport";
+    public static final String SERIALIZED_BYTES = "SerializedBytes";
 }