L.S.,
If might be the MEP of the Exchange that is being sent to the cxf:
endpoint. Could you try enabling DEBUG logging or use tracing
(http://cwiki.apache.org/CAMEL/tracer.html) to see what exchanges are
being passed along.
Regards,
Gert
Genadii Ganebnyi wrote:
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?
