在camel编组期间出现InvalidPayloadException

Posted 2021-04-14

我试图从队列中编组java对象，但即使在正确提及对象工厂类之后我也得到了InvalidPayloadException。请在下面找到我的代码：

 //JaxB Config
 JAXBContext jc = JAXBContext.newInstance(com.ObjectFactory.class);

 // POGO configuration in Jaxb component for responsexml insertion
            JaxbDataFormat jaxbMarshalXmlInsertion = new JaxbDataFormat(jc);
            jaxbMarshalXmlInsertion .setContextPath(MyPojo.class.getName());
            jaxbMarshalXmlInsertion .setPartClass(MyPojo.class.getName());



//My Route
from("vm:ResponseQueue").
 .log("In response XML body before Marshall-------------->${body}")
    .marshal(jaxbMarshalXmlInsertion )
    .log("In response XML body After Marshall-------------->${body}")
 to(vm:XmlQueue);


//Log(The log before the marshal code is printed correctly in fuse.log)
In response XML body before Marshall-------------->com.MyPojo@2cf745ca


//Excerption I got
InvalidPayloadException: No body available of type: javax.xml.bind.JAXBElement but has value: com.MyPojo@2cf745ca of type: com.MyPojoon: Message[ID-B526DCOK-51386-1514355409371-5-121]. Exchange[ID-B526DCOK-51386-1514355409371-5-122]

谁能帮助我找出我错过的内容并帮助我解决这个问题？

答案

尝试

from("vm:ResponseQueue").
 .streamCaching()
 .log("In response XML body before Marshall-------------->${body}")
    .marshal(jaxbMarshalXmlInsertion )
    .log("In response XML body After Marshall-------------->${body}")
 to(vm:XmlQueue);

查看更多详情http://camel.apache.org/stream-caching.html