Announcement Announcement Module
Collapse
No announcement yet.
Spring Integration and ActiveMQ's AMQ_SCHEDULED_DELAY property Page Title Module
Move Remove Collapse
X
Conversation Detail Module
Collapse
  • Filter
  • Time
  • Show
Clear All
new posts

  • Spring Integration and ActiveMQ's AMQ_SCHEDULED_DELAY property

    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!

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

    Comment


    • #3
      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,

      Comment


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

        Code:
        <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:

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

        Comment

        Working...
        X