Hi All,
I have the following flow:
from("activemq:vasea")
.process(new Processor() {
public void process(Exchange ex) throws Exception {
System.out.println(">>>>>>"+ex.getIn().getBody().getClass());
//ex.getIn().setBody(ex.getIn().getBody(String.class));
JAXBContext ctx = JAXBContext.newInstance(new
Class[]
{InputReportIncident.class});
Unmarshaller um = ctx.createUnmarshaller();
InputReportIncident report = (InputReportIncident)
um.unmarshal(new StringReader(ex.getIn().getBody(String.class)));
ArrayList<InputReportIncident> list = new
ArrayList<InputReportIncident>();
list.add(report);
ex.getIn().setBody(list);
ex.getIn().setHeader(CxfConstants.OPERATION_NAME, "ReportIncident");
}
})
.pipeline("cxf:bean:serviceEndpoint")
.to("activemq:petea")
;
It stops at the point where cxf is called. Can anybody help with this issue?
