You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2015/01/19 17:54:38 UTC
svn commit: r1653047 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java
Author: cwiklik
Date: Mon Jan 19 16:54:38 2015
New Revision: 1653047
URL: http://svn.apache.org/r1653047
Log:
UIMA-4066 addded fix to allow consuming of large messages from http msg body.
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java?rev=1653047&r1=1653046&r2=1653047&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverConfiguration.java Mon Jan 19 16:54:38 2015
@@ -18,6 +18,7 @@
*/
package org.apache.uima.ducc.transport.configuration.jd;
+import java.io.BufferedReader;
import java.io.IOException;
import javax.servlet.ServletException;
@@ -243,16 +244,27 @@ import org.springframework.context.annot
throws ServletException, IOException
{
try {
- char[] content = new char[request.getContentLength()];
+ StringBuilder sb = new StringBuilder();
+ BufferedReader reader = request.getReader();
+ String line;
+ while ((line = reader.readLine()) != null ) {
+ sb.append(line);
+ }
+ //char[] content = new char[request.getContentLength()];
+ String content = sb.toString().trim();
- request.getReader().read(content);
+ //char[] content = new char[request.getContentLength()];
+
+ //request.getReader().read(content);
logger.debug("doPost",jobid, "Http Request Body:::"+String.valueOf(content));
IMetaCasTransaction imt=null;
- String t = String.valueOf(content);
+ //String t = String.valueOf(content);
+// imt = (IMetaCasTransaction) XStreamUtils
+// .unmarshall(t.trim());
imt = (IMetaCasTransaction) XStreamUtils
- .unmarshall(t.trim());
+ .unmarshall(content);
// process JP's request
jdc.handleJpRequest(imt);