Author: asankha
Date: Tue Mar 24 07:02:31 2009
New Revision: 757675
URL: http://svn.apache.org/viewvc?rev=757675&view=rev
Log:
fix SYNAPSE-452
Modified:
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ServerHandler.java
Modified:
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ServerHandler.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ServerHandler.java?rev=757675&r1=757674&r2=757675&view=diff
==============================================================================
---
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ServerHandler.java
(original)
+++
synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/nhttp/ServerHandler.java
Tue Mar 24 07:02:31 2009
@@ -220,6 +220,7 @@
} else if (!connStrategy.keepAlive(response, context)) {
conn.close();
} else {
+ conn.resetOutput();
conn.requestInput();
}
}
@@ -241,6 +242,7 @@
*/
public void commitResponseHideExceptions(final NHttpServerConnection conn,
final HttpResponse response) {
try {
+ conn.suspendInput();
httpProcessor.process(response, conn.getContext());
conn.submitResponse(response);
} catch (HttpException e) {
@@ -261,6 +263,7 @@
public void commitResponse(final NHttpServerConnection conn,
final HttpResponse response) throws IOException, HttpException {
try {
+ conn.suspendInput();
httpProcessor.process(response, conn.getContext());
conn.submitResponse(response);
} catch (HttpException e) {
