How To implement a periodically polled queue.

[anupamsen]

Hi,

I have the following requirement -

1) If a message is received on the save entity route and the authentication
server is not available, then queue up the request in the
*periodicallyPolledInputQueue*.
2) The *periodicallyPolledInputQueue* thus may have n number of messages.
3) Every 30 minutes fetch all the messages in the
*periodicallyPolledInputQueue* and queue them back up to the *saveEntity*
queue using a producer template in the processor
*periodicallyPolledInputHandler* 


<route id="saveEntityRoute"
errorHandlerRef="PeriodicallyPolledInputQueue-ErrorHandler" trace="true">
  <from uri="jms:queue:JMS-Server/saveEntity?concurrentConsumers=10" />
  <camel:transacted ref="PROPAGATION_REQUIRED"/>
  <process ref="authenticator" />
  <camel:choice>
    <camel:when>
      
      <camel:simple>${header.SESSION_ID} == null and
${header.SERVER_AVAILABLE_TOKEN} == 'NO'</camel:simple>
      <to
uri="jms:queue:JMS-Server/periodicallyPolledInputQueue?disableReplyTo=true"
/>
    </camel:when>
    <camel:when>
      
      
      <camel:simple>${header.SESSION_ID} == null and
${header.SERVER_AVAILABLE_TOKEN} != 'NO'</camel:simple>
      <camel:stop></camel:stop>
    </camel:when>
    <camel:otherwise>
      <to uri="xslt:xsl/Transform.xsl" />
      <convertBodyTo type="java.lang.String"/>
      <delay><constant>300</constant></delay>
      <to uri="bean:entityData?method=saveEntity(${body},
${header.SESSION_ID}, ${header.ACK_ID})"/>
      <to uri="jms:queue:JMS-Server/saveEntityAck?disableReplyTo=true" />
    </camel:otherwise>
  </camel:choice>
</route>


<route id="periodicallyPolledInputQueueHandlerRoute">
  <from
uri="quartz://periodicallyPolledInputQueueHandler?cron=0+0/30+*+*+*+?"/>
  <camel:transacted ref="PROPAGATION_REQUIRED"/>
  <pollEnrich
uri="jms:queue:JMS-Server/periodicallyPolledInputQueue?disableReplyTo=true"/>
  <process ref="periodicallyPolledInputHandler" />
</route>

The goal is to  setup a fail-safe system that would ensure that the
integration layer is available even if the authentication system is down and
we can reprocess the messages.

The questions now -
1) Is this approach correct.
2) I tested this works but strangely just picks a single message only from
the input queue "periodicallyPolledInputQueue" even if tehre are n messages
lying. Is this teh behaviour of quarts+pollenrich on JMS?

Thanks.



--
View this message in context: 
http://camel.465427.n5.nabble.com/How-To-implement-a-periodically-polled-queue-tp5719920.html
Sent from the Camel - Users mailing list archive at Nabble.com.