Yes, I understand that, and got it working that way. I had misunderstood where the POJO binding fitted in. Thanks for your help.
Tim On 22/11/2014 09:27, Claus Ibsen wrote:
Hi The rest DSL is on the other side, eg on the server side, to exposes Camel routes as REST services. Not on the client side how to call another REST service. For POJO -> Json you can use jackson to turn that into json. On Fri, Nov 21, 2014 at 6:41 PM, Tim Dudgeon <[email protected]> wrote:OK, that figures, and I got it to work. But it seems to circumvent the whole purpose of the POJO binding with rest DSL. How are you supposed to send POJO to Rest DSL within Camel. I briefly tried using restlet like this: t.requestBody('restlet:http://$BASE_URL/foo?restletMethod=POST', p) but that didn't work. Thanks Tim On 21/11/2014 17:12, Claus Ibsen wrote:Hi Its the client code you write to send the Person using http4. It does not know how to convert that to json. You need to convert it to json first, and then send that instead of the Person java object. On Fri, Nov 21, 2014 at 5:56 PM, Tim Dudgeon <[email protected]> wrote:I'm having problems getting POJO binding working with the Rest DSL. I put together a simple example in Groovy, but it fails: package com.im.examples.search import org.apache.camel.CamelContext import org.apache.camel.ProducerTemplate import org.apache.camel.builder.RouteBuilder import org.apache.camel.impl.DefaultCamelContext import org.apache.camel.model.rest.RestBindingMode import org.apache.camel.model.dataformat.JsonLibrary String HOST = 'localhost' String PORT = '43256' String BASE_URL = "$HOST:$PORT/search" class Person { String firstName String lastName } CamelContext camelContext = new DefaultCamelContext() camelContext.addRoutes(new RouteBuilder() { def void configure() { restConfiguration().component("restlet").host(HOST).port(PORT).bindingMode(RestBindingMode.json) rest("/search") .post("/foo").type(Person.class).to("direct:end") from('direct:end') .log('${body}') .transform().constant('Welcome') from('direct:testmarshal') .marshal().json(JsonLibrary.Jackson) .log('JSON: ${body}') } }) camelContext.start() Person p = new Person(firstName: 'John', lastName: 'Doe') ProducerTemplate t = camelContext.createProducerTemplate() t.sendBody('direct:testmarshal', p) def resp = t.requestBody("http4:$BASE_URL/foo", p) println "resp: $resp" camelContext.stop() The error I get is: Caused by: org.apache.camel.InvalidPayloadException: No body available of type: java.io.InputStream but has value: com.im.examples.search.Person@6c4b8217 of type: com.im.examples.search.Person on: Message: com.im.examples.search.Person@6c4b8217. Caused by: No type converter available to convert from type: com.im.examples.search.Person to the required type: java.io.InputStream with value com.im.examples.search.Person@6c4b8217. Exchange[Message: com.im.examples.search.Person@6c4b8217]. Caused by: [org.apache.camel.NoTypeConversionAvailableException - No type converter available to convert from type: com.im.examples.search.Person to the required type: java.io.InputStream with value com.im.examples.search.Person@6c4b8217] at org.apache.camel.impl.MessageSupport.getMandatoryBody(MessageSupport.java:101) at org.apache.camel.component.http4.HttpProducer.createRequestEntity(HttpProducer.java:461) at org.apache.camel.component.http4.HttpProducer.createMethod(HttpProducer.java:368) at org.apache.camel.component.http4.HttpProducer.process(HttpProducer.java:106) at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61) at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) at org.apache.camel.processor.UnitOfWorkProducer.process(UnitOfWorkProducer.java:74) at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:375) at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:343) at org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:233) at org.apache.camel.impl.ProducerCache.sendExchange(ProducerCache.java:343) at org.apache.camel.impl.ProducerCache.send(ProducerCache.java:201) at org.apache.camel.impl.DefaultProducerTemplate.send(DefaultProducerTemplate.java:128) at org.apache.camel.impl.DefaultProducerTemplate.sendBody(DefaultProducerTemplate.java:132) ... 28 more Caused by: org.apache.camel.NoTypeConversionAvailableException: No type converter available to convert from type: com.im.examples.search.Person to the required type: java.io.InputStream with value com.im.examples.search.Person@6c4b8217 at org.apache.camel.impl.converter.BaseTypeConverterRegistry.mandatoryConvertTo(BaseTypeConverterRegistry.java:182) at org.apache.camel.impl.MessageSupport.getMandatoryBody(MessageSupport.java:99) ... 41 more I thought I had carefully followed the documentation :-( Can anyone help spot what is wrong? Thanks Tim
