Spring Integration Poller Cron not working

[Former Member]

Hi All,

In our datahub implementation we are pulling the data from API's and pushing it.We have implemented by using the below spring integration.

I am facing issue with poller cron , as its not getting invoked when the method loadNewProducts is running longer than 59 mintues.

 <inbound-channel-adapter channel="ibcaChannel" auto-startup="true" ref="ibcaBean" method="prepareMessage">
         <poller cron="0 0/59 * * * *"></poller>
     </inbound-channel-adapter>
 
     <service-activator input-channel="ibcaChannel" ref="newProductHierarchy" method="retrieveAndLoadProductHirarchy" output-channel="newProductsChannel" /> 
 
     <service-activator input-channel="newProductsChannel" ref="newProducts" method="loadNewProducts" output-channel="routingChannel" />
     
     <header-value-router input-channel="routingChannel" header-name="Validator">
         <mapping value="Failure" channel="terminateChannel"/>
         <mapping value="Success" channel="updateProductStatusChannel"/>
     </header-value-router>
     
     <service-activator input-channel="terminateChannel" ref="killService" method="stopProductCreateService" output-channel="endChannel" />
     
     <service-activator input-channel="updateProductStatusChannel" ref="runningStatus" method="settingStatus" output-channel="endChannel" />

Thanks in Advance.

[arvind-kumar_avinash]

Can you please try with 0 0/59 * 1/1 * ? * as the cron expression?

[Former Member]

Could you please tell me what will happen if i use the above mentioned cron expression?As, i want the poller cron to be triggered for every 59th minute of an hour.

[Former Member]

I got the following error after changing the cron expression:

 Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.scheduling.support.CronTrigger]: Constructor threw exception; nested exception is java.lang.IllegalArgumentException: Cron expression must consist of 6 fields (found 7 in "0 0/59 * 1/1 * ? *")

[arvind-kumar_avinash]

The cron expression, 0 0/59 * 1/1 * ? * also translates to every 59 minutes ( you can check at https://cronexpressiondescriptor.azurewebsites.net/ ). However, it seems it can accept only 6 fields. In that case, you can try removing the last * i.e. the cron expression will be 0 0/59 * 1/1 * ?. Please note that there is no problem with your cron expression; but I just wanted to try a different expression.

Did you try increasing the time interval? Is there a strict business requirement that the job should run every 59 minutes?

[mpern]

AFAIK, this is expected behaviour for Spring Integration. The next trigger will only occur if the previous completes.

You need to hand of the processing of loadNewProducts to a different thread using a QueueChannel or ExecutorChannel to ensure the processing is triggered exactly every 59 minutes. But beware of the load on the server in that case and potential multithreading issues, because you load two potentially conflicting data sets in parallel.

Check this Spring forum thread:

http://forum.spring.io/forum/spring-projects/integration/130289-how-to-poller-to-wait-for-first-poll...