You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@camel.apache.org by swapna07 <sw...@gmail.com> on 2016/04/26 04:32:52 UTC
camel route not posting the message to mq
I have following camel route, reading from a queue (btrRTTransReqQueue)
converting the message to another jaxb object, and post it into another
queue(Req.queueName) which has reply to queue (Res.queueName)set, when the
response message available on reply queue read from that queue and process
it and post back to another queue(btrRTTransResQueue).
When i run this i am not seeing any exceptions but could not able to see the
request being posted to req queue(Req.queueName) after processing in
preprocessor. I have hard time figuring out what was wrong here.
<camel:endpoint id="BankTranReq"
uri="mq:${Req.queueName}?replyTo=${Res.queueName}&timeToLive=${services.connectionTimeout}&requestTimeout=${currentDayTran.requestTimeout}&replyToType=Exclusive&useMessageIDAsCorrelationID=true"/>
<camel:endpoint id="btrRTTransReqQueue"
uri="mq:${CDGirTransReq.queueName}"/>
<camel:endpoint id="btrRTTransResQueue"
uri="mq:${CDGirTransRes.queueName}"/>
<camel:route>
<camel:from ref="btrRTTransReqQueue"/>
<camel:to
uri="log:com.integrationplatform?skipBodyLineSeparator=false" />
<camel:unmarshal>
<camel:jaxb prettyPrint="true"
contextPath="com.integrationservices.model.message.btr.v1"
partClass="com.integrationservices.model.message.btr.v1.StatementRequest"
/>
</camel:unmarshal>
<camel:to uri="direct:getAccountStatements"/>
<camel:marshal>
<camel:jaxb prettyPrint="true"
contextPath="com.integrationservices.model.message.btr.v1"
partClass="com.integrationservices.model.message.btr.v1.StatementResponse"
partNamespace="{http://www.schema.com/external/message/currentdaytransaction/v1}currentDayAccountStatementResponse"
fragment="true" />
</camel:marshal>
<camel:to
uri="log:com.integrationplatform?skipBodyLineSeparator=false" />
<camel:to ref="btrRTTransResQueue"/>
</camel:route>
<camel:route>
<camel:from uri="direct:getAccountStatements"/>
<camel:setExchangePattern pattern="InOut"/>
<camel:process ref="getAccountStatements_PreProcessor"/>
<camel:marshal>
<camel:jaxb prettyPrint="true"
contextPath="com.interfaces.schema.message.host"
partClass="com.interfaces.schema.message.host.AcctInqRqType"
partNamespace="AcctInqRq"
fragment="true" />
</camel:marshal>
<camel:to ref="BankTranReq"/>
<camel:unmarshal>
<camel:jaxb id="getAcctStmtJaxbResponse" prettyPrint="false"
contextPath="com.interfaces.schema.message.host"
partClass="com.interfaces.schema.message.host.AcctInqRsType"
partNamespace="AcctInqRs"
/>
</camel:unmarshal>
<camel:process ref="getAccountStatements_PostProcessor"/>
</camel:route>
--
View this message in context: http://camel.465427.n5.nabble.com/camel-route-not-posting-the-message-to-mq-tp5781693.html
Sent from the Camel Development mailing list archive at Nabble.com.
Re: camel route not posting the message to mq
Posted by Matt Pavlovich <ma...@gmail.com>.
Hi-
This question is best suited for the camel-users list. camel-dev is
geared for the development of the Camel itself.
Would you please post this questions over on that list? Also, it'd be
helpful if you posted this code to a website like pastebin or other
where the code can be formatted for easier reading. Please include the
component bean wiring and details about what type of runtime you are
using.. JBoss Fuse, ServiceMix, Talend, raw JVM, etc.
Thanks!
Matt
On 4/25/16 9:32 PM, swapna07 wrote:
> I have following camel route, reading from a queue (btrRTTransReqQueue)
> converting the message to another jaxb object, and post it into another
> queue(Req.queueName) which has reply to queue (Res.queueName)set, when the
> response message available on reply queue read from that queue and process
> it and post back to another queue(btrRTTransResQueue).
>
> When i run this i am not seeing any exceptions but could not able to see the
> request being posted to req queue(Req.queueName) after processing in
> preprocessor. I have hard time figuring out what was wrong here.
>
> <camel:endpoint id="BankTranReq"
> uri="mq:${Req.queueName}?replyTo=${Res.queueName}&timeToLive=${services.connectionTimeout}&requestTimeout=${currentDayTran.requestTimeout}&replyToType=Exclusive&useMessageIDAsCorrelationID=true"/>
> <camel:endpoint id="btrRTTransReqQueue"
> uri="mq:${CDGirTransReq.queueName}"/>
> <camel:endpoint id="btrRTTransResQueue"
> uri="mq:${CDGirTransRes.queueName}"/>
> <camel:route>
> <camel:from ref="btrRTTransReqQueue"/>
> <camel:to
> uri="log:com.integrationplatform?skipBodyLineSeparator=false" />
> <camel:unmarshal>
> <camel:jaxb prettyPrint="true"
> contextPath="com.integrationservices.model.message.btr.v1"
>
> partClass="com.integrationservices.model.message.btr.v1.StatementRequest"
> />
> </camel:unmarshal>
> <camel:to uri="direct:getAccountStatements"/>
> <camel:marshal>
> <camel:jaxb prettyPrint="true"
> contextPath="com.integrationservices.model.message.btr.v1"
>
> partClass="com.integrationservices.model.message.btr.v1.StatementResponse"
>
> partNamespace="{http://www.schema.com/external/message/currentdaytransaction/v1}currentDayAccountStatementResponse"
> fragment="true" />
> </camel:marshal>
> <camel:to
> uri="log:com.integrationplatform?skipBodyLineSeparator=false" />
> <camel:to ref="btrRTTransResQueue"/>
> </camel:route>
>
> <camel:route>
> <camel:from uri="direct:getAccountStatements"/>
> <camel:setExchangePattern pattern="InOut"/>
> <camel:process ref="getAccountStatements_PreProcessor"/>
> <camel:marshal>
> <camel:jaxb prettyPrint="true"
> contextPath="com.interfaces.schema.message.host"
> partClass="com.interfaces.schema.message.host.AcctInqRqType"
> partNamespace="AcctInqRq"
> fragment="true" />
> </camel:marshal>
> <camel:to ref="BankTranReq"/>
> <camel:unmarshal>
> <camel:jaxb id="getAcctStmtJaxbResponse" prettyPrint="false"
> contextPath="com.interfaces.schema.message.host"
> partClass="com.interfaces.schema.message.host.AcctInqRsType"
> partNamespace="AcctInqRs"
> />
> </camel:unmarshal>
> <camel:process ref="getAccountStatements_PostProcessor"/>
> </camel:route>
>
>
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/camel-route-not-posting-the-message-to-mq-tp5781693.html
> Sent from the Camel Development mailing list archive at Nabble.com.