Again, stream caching will resolve this, but, as you said earlier, you get an exception because stream caching changes the object in the message payload. Apparently there's no converter from InputStreamCache to javax.ws.rs.core.Response, which is a bit surprising as this seems a common use case.
You can try writing your own type converters[1] [1] http://camel.apache.org/type-converter.html On Tue, Oct 25, 2016 at 3:01 PM, Steve Huston <shus...@riverace.com> wrote: > I'm having trouble accessing the Response... in the debugger I stopped it > and show the Response entity member as: > > entity HttpURLConnection$HttpInputStream (id=73) > > If I try to touch it it throws an exception that the stream is closed. > > On return from the web service call, I have these message properties: > BodyType:org.apache.cxf.jaxrs.impl.ResponseImpl, > Body:{"employeeID":"jdoe27","reason":"The specified employee does not > exist."} > > -Steve > > > -----Original Message----- > > From: Aravind Rajasekharan Pillai [mailto:aravindrajasekha...@gmail.com] > > Sent: Tuesday, October 25, 2016 5:28 PM > > To: users@camel.apache.org > > Subject: Re: Trouble accessing Response body content from RESTful call > > > > Hi > > > > I don't think you can do a direct conversion to string I think u need > to read it > > as a buffered input stream and convert to string. Can you try it that way > > > > Regards > > Aravind > > > > > On Oct 25, 2016, at 4:41 PM, Steve Huston <shus...@riverace.com> > wrote: > > > > > > Thank you for replying, Aravind! > > > > > > Also interesting - I had a LoggingFeature added to the > > JAXRSClientFactoryBean with which I set up the web service. I removed > that > > (and removed the stream cache enabling to get back to starting point). > With > > that, I can get a Response into my handler after invoking the service, > but > > trying to read the response entity as: > > > > > > String body = wsResponse.readEntity(String.class); > > > > > > I get an exception: > > > javax.ws.rs.client.ResponseProcessingException: Problem with reading > the > > data, class java.lang.String, ContentType: application/json;charset=UTF- > 8. > > > at > > org.apache.cxf.jaxrs.impl.ResponseImpl.reportMessageHandlerProblem(Res > > ponseImpl.java:439) > > > at > > org.apache.cxf.jaxrs.impl.ResponseImpl.doReadEntity(ResponseImpl.java:37 > > 9) > > > at > > org.apache.cxf.jaxrs.impl.ResponseImpl.readEntity(ResponseImpl.java:320) > > > at > > > org.apache.cxf.jaxrs.impl.ResponseImpl.readEntity(ResponseImpl.java:31 > > > 0) > > > ... in my code > > > Caused by: java.io.IOException: stream is closed > > > at > > sun.net.www.protocol.http.HttpURLConnection$HttpInputStream.ensureOp > > en(HttpURLConnection.java:3308) > > > at > > sun.net.www.protocol.http.HttpURLConnection$HttpInputStream.read(Http > > URLConnection.java:3333) > > > at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284) > > > at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326) > > > at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178) > > > at java.io.InputStreamReader.read(InputStreamReader.java:184) > > > at java.io.Reader.read(Reader.java:140) > > > at org.apache.cxf.helpers.IOUtils.toString(IOUtils.java:316) > > > at org.apache.cxf.helpers.IOUtils.toString(IOUtils.java:304) > > > at org.apache.cxf.helpers.IOUtils.toString(IOUtils.java:288) > > > at > > org.apache.cxf.jaxrs.provider.StringTextProvider.readFrom( > StringTextProvid > > er.java:45) > > > at > > org.apache.cxf.jaxrs.provider.StringTextProvider.readFrom( > StringTextProvid > > er.java:36) > > > at > > org.apache.cxf.jaxrs.utils.JAXRSUtils.readFromMessageBodyReader(JAXRSU > > tils.java:1366) > > > at > > org.apache.cxf.jaxrs.impl.ResponseImpl.doReadEntity(ResponseImpl.java:37 > > 0) > > > ... 23 more > > > > > >> -----Original Message----- > > >> From: aravind r [mailto:aravindrajasekha...@gmail.com] > > >> Sent: Tuesday, October 25, 2016 1:39 PM > > >> To: users@camel.apache.org > > >> Subject: Re: Trouble accessing Response body content from RESTful > > >> call > > >> > > >> Hi Steve, > > >> > > >> Are u logging the Message body somewhere before consuming (say > > Camel > > >> logger in between),that could also lead to input stream consumption. > > >> > > >> Regards, > > >> Aravind > > >> > > >> On Tue, Oct 25, 2016 at 1:15 PM, Doug Douglass > > >> <douglass.d...@gmail.com> > > >> wrote: > > >> > > >>> I can't say where the response body is being consumed, but try > > >>> enabling stream caching[1] and see what you get. > > >>> > > >>> Doug > > >>> > > >>> [1] http://camel.apache.org/stream-caching.html > > >>> > > >>> On Tue, Oct 25, 2016 at 9:31 AM, Steve Huston <shus...@riverace.com> > > >>> wrote: > > >>> > > >>>> I am developing a route that calls a web service; said web service > > >>> returns > > >>>> a JSON string (Not always the same type represented). I have this > > >>>> in a route as: > > >>>> > > >>>> from(myqueue) > > >>>> .bean(SetupCxfRequest.class) // This sets up > parameters for > > >>>> REST API call > > >>>> > > .convertBodyTo(org.apache.cxf.message.MessageContentsList.class) > > >>>> .to("cxfrs:bean:ws?throwExceptionOnFailure=false") > > >>>> .bean(WebServiceResponse.class) > > >>>> > > >>>> SetupCxfRequest will: > > >>>> exchange.setPattern(ExchangePattern.InOut); > > >>>> // Indicate using Proxy API. > > >>>> in.setHeader(CxfConstants.CAMEL_CXF_RS_USING_HTTP_API, > > >>>> Boolean.FALSE); > > >>>> in.setHeader(CxfConstants.OPERATION_NAME, > > >>>> VerifyEmployeeRequest); > > >>>> > > >>>> The web service interface method for the call in question is: > > >>>> @GET > > >>>> @Path(value="/authentication/{company}/employees/{id}") > > >>>> @Produces({ MediaType.APPLICATION_JSON }) > > >>>> public Response VerifyEmployeeRequest(@PathParam("company") > > >>>> String scac, > > >>>> @PathParam("id") String id, > > >>>> @QueryParam("pin") String > pin, > > >>>> @QueryParam("reason") > > >>>> String reason); > > >>>> > > >>>> The case I'm working now is that the web service is called and it > > >>>> returns a 404 status with a body of JSON-marshaled stuff I need to > get > > at. > > >>>> From my route above, WebServiceResponse is then called as: > > >>>> > > >>>> public class WebServiceResponse { > > >>>> > > >>>> @Handler > > >>>> public Object convertWebServiceResponse(Response wsResponse, > > >>>> Exchange exchange) throws IOException { ObjectMapper unmarshaller > > = > > >>>> new ObjectMapper(); > > >>>> Class<?> target = null; > > >>>> Message in = exchange.getIn(); > > >>>> int opStatus = wsResponse.getStatus(); > > >>>> if (opStatus == 200) > > >>>> target = EmployeeVerificationResponseAc > > >>> cept.class; > > >>>> else > > >>>> target = > > >>>> EmployeeVerificationResponseDeny.class; > > >>>> > > >>>> So far, so good - opStatus is 404. I need to get the string which > > >>>> is the response body and then unmarshall it. > > >>>> wsResponse.entity is a SequenceInputStream and one of the input > > >>>> streams appears to be the string I'm expecting from the web > > >>>> service; however, it has been completely consumed (length and > > >>>> position are the same). Where > > >>> did > > >>>> it go, and how can I get it? > > >>>> > > >>>> Thanks, > > >>>> -Steve > > >>>> > > >>>> > > >>> >
