You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by fachhoch <fa...@gmail.com> on 2011/06/14 21:36:32 UTC
jms queue endpoint message parameters
I have my route with endpoint to jms queue,
here
from("file://e:/u01/oracle/NEW_NEAR_FILES/?delay=60000&move=../PROCESSED_NEAR_FILES")
.convertBodyTo(String.class)
.aggregate(constant(true)).completionSize(10).completionTimeout(10000L).groupExchanges()
.process(new FileProcessor()).to("jms:queue:batch");
the FileProcessor inserts a record into my database , the PK key of
this record I want to send to my jms queue batch , please tell me how to add
this parameter to jms enpoint
--
View this message in context: http://camel.465427.n5.nabble.com/jms-queue-endpoint-message-parameters-tp4489020p4489020.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: jms queue endpoint message parameters
Posted by boday <be...@initekconsulting.com>.
in the FileProcessor, just call exchange.getIn().setBody(<PK>)...the body of
the exchange will be used for to create the JMS message, etc...
fachhoch wrote:
>
> I have my route with endpoint to jms queue,
>
> here
>
>
>
> from("file://e:/u01/oracle/NEW_NEAR_FILES/?delay=60000&move=../PROCESSED_NEAR_FILES")
> .convertBodyTo(String.class)
> .aggregate(constant(true)).completionSize(10).completionTimeout(10000L).groupExchanges()
> .process(new FileProcessor()).to("jms:queue:batch");
>
>
>
> the FileProcessor inserts a record into my database , the PK key of
> this record I want to send to my jms queue batch , please tell me how to
> add this parameter to jms enpoint
>
-----
Ben O'Day
IT Consultant -http://consulting-notes.com
--
View this message in context: http://camel.465427.n5.nabble.com/jms-queue-endpoint-message-parameters-tp4489020p4489225.html
Sent from the Camel - Users mailing list archive at Nabble.com.