Spring Integration and ActiveMQ's AMQ_SCHEDULED_DELAY property

[igor.bljahhin]

Hello,

I would like to use ActiveMQ's scheduled processing feature (http://activemq.apache.org/delay-and...-delivery.html). I can set the value to AMQ_SCHEDULED_DELAY header of JMS message and it is passed to ActiveMQ, but JMS is processed by Spring Integration's "jms:message-driven-channel-adapter" right away. Does anybody implemented scheduling of JMS with Spring Integration and ActiveMQ? Please, give me some advice.

Thank you in advance!

[igor.bljahhin]

I set "schedulerSupport" to "true" in broker's configuration's and now scheduling is working.

[santhosh666]

Hi,
I have the same requirement of using AMQ_SCHEDULED_DELAY feature with Spring INtegration and Active MQ..

it would be great if you could share the broker confifuration and SI configuration for the same..

Appreciate your help..

Thanks,

[igor.bljahhin]

That was quite easy. We should add header to Spring Integration message:

<header-enricher input-channel="social-verify-channel-reschedule" output-channel="social-verify-channel">
    <!-- schedule message sent to ActiveMQ: it will be processed with delay in 1 hour -->
    <header name="AMQ_SCHEDULED_DELAY" value="3600000" />
</header-enricher>

In activemq.xml we have "schedulerSupport" enabled:

<broker xmlns="http://activemq.apache.org/schema/core" useJmx="true" brokerName="localhost" dataDirectory="${activemq.data}" destroyApplicationContextOnStop="true" schedulerSupport="true">
...