svn commit: r761507 - /synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java

[ruwan]

Author: ruwan
Date: Fri Apr  3 02:30:13 2009
New Revision: 761507

URL: http://svn.apache.org/viewvc?rev=761507&view=rev
Log:
100 char limit fixing

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

Modified: 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java?rev=761507&r1=761506&r2=761507&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java
 (original)
+++ 
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ClientHandler.java
 Fri Apr  3 02:30:13 2009
@@ -173,7 +173,8 @@
             conn.getMetrics().reset();
 
             HttpContext context = conn.getContext();
-            ContentOutputBuffer outputBuffer = new 
SharedOutputBuffer(cfg.getBufferSize(), conn, allocator);
+            ContentOutputBuffer outputBuffer
+                    = new SharedOutputBuffer(cfg.getBufferSize(), conn, 
allocator);
             axis2Req.setOutputBuffer(outputBuffer);
             context.setAttribute(REQUEST_SOURCE_BUFFER, outputBuffer);
 
@@ -452,12 +453,14 @@
                     if (metrics.getLevel() == MetricsCollector.LEVEL_FULL) {
                         MessageContext mc = getMessageContext(conn);
                         metrics.incrementMessagesReceived(mc);
-                        metrics.notifyReceivedMessageSize(mc, 
conn.getMetrics().getReceivedBytesCount());
+                        metrics.notifyReceivedMessageSize(
+                                mc, conn.getMetrics().getReceivedBytesCount());
                         metrics.notifySentMessageSize(mc, 
conn.getMetrics().getSentBytesCount());
                         metrics.reportResponseCode(mc, 
response.getStatusLine().getStatusCode());
                     } else {
                         metrics.incrementMessagesReceived();
-                        
metrics.notifyReceivedMessageSize(conn.getMetrics().getReceivedBytesCount());
+                        metrics.notifyReceivedMessageSize(
+                                conn.getMetrics().getReceivedBytesCount());
                         
metrics.notifySentMessageSize(conn.getMetrics().getSentBytesCount());
                     }
                 }
@@ -497,7 +500,8 @@
     public void outputReady(final NHttpClientConnection conn, final 
ContentEncoder encoder) {
         HttpContext context = conn.getContext();
 
-        ContentOutputBuffer outBuf = (ContentOutputBuffer) 
context.getAttribute(REQUEST_SOURCE_BUFFER);
+        ContentOutputBuffer outBuf
+                = (ContentOutputBuffer) 
context.getAttribute(REQUEST_SOURCE_BUFFER);
         if (outBuf == null) return;
 
         try {
@@ -534,7 +538,8 @@
         HttpResponse response = conn.getHttpResponse();
 
         // Have we sent out our request fully in the first place? if not, 
forget about it now..
-        Axis2HttpRequest req = (Axis2HttpRequest) 
conn.getContext().getAttribute(AXIS2_HTTP_REQUEST);
+        Axis2HttpRequest req
+                = (Axis2HttpRequest) 
conn.getContext().getAttribute(AXIS2_HTTP_REQUEST);
         
         if (req != null) {
             req.setCompleted(true);
@@ -542,7 +547,8 @@
                 log.debug("Response Received for Request : " + req);
             }
             if (!req.isSendingCompleted()) {
-                req.getMsgContext().setProperty(NhttpConstants.ERROR_CODE, 
NhttpConstants.SEND_ABORT);
+                req.getMsgContext().setProperty(
+                        NhttpConstants.ERROR_CODE, NhttpConstants.SEND_ABORT);
                 SharedOutputBuffer outputBuffer = (SharedOutputBuffer)
                         conn.getContext().getAttribute(REQUEST_SOURCE_BUFFER);
                 if (outputBuffer != null) {