camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Felix Thomas <felix.tho...@gmail.com>
Subject Send Message to a queue before start & end of a route starts prcoessing
Date Fri, 28 Aug 2015 12:36:52 GMT
Hello,

    I have set a Timer componet pointing to a DB, which is triggered at
some interval.  I want to send a message to a queue with some value set in
the Header before the processing starts & after its ends .

Like

Message -    STARTED
Message - DATA1
Message - DATA2
Message -   END


I tried the below approach i don't see any message in the queue

  <route customId="false" id="routeMASTER1"
            xmlns="http://camel.apache.org/schema/spring">
            <from uri="timer://getData?period=2h" />
            <process ref="CustomHeaderProcessor" />
            <onCompletion mode="BeforeConsumer">
                  <setHeader headerName="TAG">
                    <constant>START</constant>
                  </setHeader>
                  <to
uri="rabbitmq://Localhost/MSEXCHANGE?autoDelete=false&amp;queue=MS&amp;username=XXXX&amp;password=XXX&amp;routingKey=DAMS"
                            id="to4" />
            </onCompletion>
            <onCompletion mode="AfterConsumer">
                  <setHeader headerName="TAG">
                    <constant>END</constant>
                  </setHeader>
                  <to
uri="rabbitmq://localhost/MSEXCHANGE?autoDelete=false&amp;queue=MS&amp;username=XXXX&amp;password=XXX&amp;routingKey=DAMS"
                            id="to5" />
            </onCompletion>
            <setBody id="setBody1">
                <constant>select * from TEST</constant>
            </setBody>
            <to uri="jdbc:DS?outputType=StreamList&amp;statement.maxRows=3"
id="to1" />
               ..............................
:::::::::::::::::::::::::::::::::::::::::::

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message