[ https://issues.apache.org/jira/browse/CAMEL-9768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Claus Ibsen resolved CAMEL-9768. -------------------------------- Resolution: Fixed Thanks. I added a so the stream is closed later so we cleanup nicely. > HTTP[4] component disableStreamCache issue: java.io.IOException: Attempted > read from closed stream. > --------------------------------------------------------------------------------------------------- > > Key: CAMEL-9768 > URL: https://issues.apache.org/jira/browse/CAMEL-9768 > Project: Camel > Issue Type: Bug > Components: camel-http4 > Affects Versions: 2.17.0 > Reporter: Edward Welch > Assignee: Claus Ibsen > Fix For: 2.17.1, 2.18.0 > > > This issue is related to CAMEL-7638 which was recently fixed/released in > 2.17.0 > I was doing some testing with disableStreamCache=true on a http4 producer and > am getting "java.io.IOException: Attempted read from closed stream" > The stack trace shows the error occurring when trying to copy the input > stream to an output stream inside the DefaultHttpBinding copyStream methods > (i am using camel as a proxy from a sevlet component (consumer) to an http4 > component (producer)). > I think though, I see the root cause of this issue. Inside the HttpProducer > process method. > {code} > // lets store the result in the output message. > HttpResponse httpResponse = null; > try { > if (LOG.isDebugEnabled()) { > LOG.debug("Executing http {} method: {}", > httpRequest.getMethod(), httpRequest.getURI().toString()); > } > httpResponse = executeMethod(httpRequest); > int responseCode = httpResponse.getStatusLine().getStatusCode(); > LOG.debug("Http responseCode: {}", responseCode); > if (!throwException) { > // if we do not use failed exception then populate response > for all response codes > populateResponse(exchange, httpRequest, httpResponse, in, > strategy, responseCode); > } else { > boolean ok = HttpHelper.isStatusCodeOk(responseCode, > getEndpoint().getOkStatusCodeRange()); > if (ok) { > // only populate response for OK response > populateResponse(exchange, httpRequest, httpResponse, in, > strategy, responseCode); > } else { > // operation failed so populate exception to throw > throw populateHttpOperationFailedException(exchange, > httpRequest, httpResponse, responseCode); > } > } > } finally { > if (httpResponse != null) { > try { > EntityUtils.consume(httpResponse.getEntity()); > } catch (IOException e) { > // nothing we could do > } > } > } > {code} > Specifically, that finally block at the end. > When disableStreamCache=true is set on the Producer, the raw input stream is > put in the exchange body, which was the change fixed by CAMEL-7638 > However, the finally block is consuming and closing that input stream making > it unusable later when we try to copy it to the servlet output stream to send > back to the caller. > I think the fix for this would be to check the endpoint to see if > disableStreamCaching is set prior to consuming the entity in the finally > block, perhaps something like this: > {code} > ... > } finally { > if (httpResponse != null && > !getEndpoint().isDisableStreamCache()) { > try { > EntityUtils.consume(httpResponse.getEntity()); > } catch (IOException e) { > // nothing we could do > } > } > } > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)