Agfdhyk

I have this Camel rest endpoint that receives leads in json format:

<rests id="restLeads" xmlns="http://camel.apache.org/schema/spring">

    <rest path="/leads">

        <post id="createLead" uri="/" consumes="application/json" >

            <to uri="direct:leads"/>

        </post>

    </rest>

</rests>

The next route in the processing pipe is:

    onException(PredicateValidationException.class)

            .handled(true)

            .setHeader(Exchange.HTTP_RESPONSE_CODE).simple("400").to("log:validationError");



    from("direct:leads")

            .id("leadEnricher")

            .unmarshal().json(Lead.class, null)

            .validate(it -> {

                final Lead lead = it.getIn().getBody(Lead.class);

                return lead.isValid();

            })

            ...

Here the lead is unmarshalled and validated. If it does validate, everything works fine. However, when there is a validation error the onException block is triggered and I can see the correct log:validationError message:

validationError  INFO - Exchange[ExchangePattern: InOut, BodyType: com.codependent.dto.Lead, Body: Lead(email=null, product=HOME, pricing=20.0)]

Besides, the calling client gets the expected 400 error code: HTTP/1.1 400 Bad Request.

Although it seems to work fine, at the end of the log I get this error:

o.a.c.c.s.CamelHttpTransportServlet ERROR - Error processing request

java.io.IOException: Stream closed

    at org.apache.catalina.connector.InputBuffer.read(InputBuffer.java:372) ~[tomcat-embed-core-8.0.36.redhat-30.jar:8.0.36]

    at org.apache.catalina.connector.CoyoteInputStream.read(CoyoteInputStream.java:156) ~[tomcat-embed-core-8.0.36.redhat-30.jar:8.0.36]

    at org.apache.camel.util.IOHelper.copy(IOHelper.java:202) ~[camel-core-2.21.0.fuse-000112-redhat-3.jar:2.21.0.fuse-000112-redhat-3]

    at org.apache.camel.http.common.DefaultHttpBinding.copyStream(DefaultHttpBinding.java:432) ~[camel-http-common-2.21.0.fuse-000112-redhat-3.jar:2.21.0.fuse-000112-redhat-3]

    at org.apache.camel.http.common.DefaultHttpBinding.doWriteDirectResponse(DefaultHttpBinding.java:496) ~[camel-http-common-2.21.0.fuse-000112-redhat-3.jar:2.21.0.fuse-000112-redhat-3]

    at org.apache.camel.http.common.DefaultHttpBinding.doWriteResponse(DefaultHttpBinding.java:395) ~[camel-http-common-2.21.0.fuse-000112-redhat-3.jar:2.21.0.fuse-000112-redhat-3]

    at org.apache.camel.http.common.DefaultHttpBinding.writeResponse(DefaultHttpBinding.java:322) ~[camel-http-common-2.21.0.fuse-000112-redhat-3.jar:2.21.0.fuse-000112-redhat-3]

Why am I getting the stream closed error?

UPDATE:

Oddly enough if I explicitly set the body, the error doesn't show up anymore, why?

onException(PredicateValidationException.class)

            .handled(true)

            .setBody().simple("Validation error for: ${body}")

            .setHeader(Exchange.HTTP_RESPONSE_CODE).simple("400").to("log:validationError");