Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
MIME-Version: 1.0
From: Daniel Arias Ramirez <darias@koghi.com>
Date: Mon, 21 Nov 2016 10:29:25 -0500
Message-ID: <CACs-4oqja-35+R=+Qy0+Vn95u44HB8g6+Od6+O81_mqyBdCjkw@mail.gmail.com>
Subject: send reply body after finishing complete route
To: users@camel.apache.org
Content-Type: multipart/alternative; boundary=001a114e3ac62a16340541d15208
archived-at: Mon, 21 Nov 2016 15:39:48 -0000

--001a114e3ac62a16340541d15208
Content-Type: text/plain; charset=UTF-8

Hi, I'm trying to make a synchronous call to an activemq sending a body
right after I process some rest service invocation. Here is my code:

some process here.. sent to this route.

private String velocitySetThirdPartyTemplate =
"velocity:file://url/velocity/file/SetThirdParty_Template.vm";

from("direct:QueueThirdParty")
                .process(new ProcessThirdPartyError())
                .marshal()
                .xstream("UTF-8")
// wait for the body when the response of the Web Service is 200 ok
                .to(ExchangePattern.InOut,"jms:queue:CreateThirdParty")
                .to("activemq:queue:somequeue");

from("jms:queue:CreateThirdParty")
                .transacted()
                .unmarshal()
                .xstream()
                .process(new SetBodyThirdParty())->this route define body
as an ArrayList of Pojo
                .split(body())
                .to(velocitySetThirdPartyTemplate)->this velocity make the
json required for the Web Service
                .process(new RestHeadersSetThirdParty())
                .to("restlet:<a href="http://ip:port
/Web/Service/url">http://ip:port/Web/Service/url"
                                        +
"?restletMethod=post&throwExceptionOnFailure")
                .process(new ResponseProcess())
                .log("response ${in.body.getStatus().getCode()}")
                .process(new SetExchangeInOutBody()); -> this final process
set the body that I want to                                            send
to the activemq in that is waiting for the reply.

the problem is that the body that is sending to the end point
"activemq:queue:somequeue" after waiting for a reply is the ArrayList of
POJO before the split.

Any Idea of how to send the body of the ".process(new
SetExchangeInOutBody());" that is the one I need.

Thanks in advance.

Daniel Felipe Arias.

--001a114e3ac62a16340541d15208--