AMQ_SCHEDULED_DELAY is not delaying message when use stomp.py

Question

I am running ActiveMQ server on docker container.

I am using AMQ_SCHEDULED_DELAY headers to delay the message.

import time
import sys

import stomp

class MyListener(stomp.ConnectionListener):
    def on_error(self, headers, message):
        print('received an error "%s"' % message)
    def on_message(self, headers, message):
        print "Time for message receive: %s", time.strftime('%H:%M:%S')
        print('received a message "%s"' % message)

conn = stomp.Connection()
conn.set_listener('', MyListener())
conn.start()
conn.connect(wait=True)

conn.subscribe(destination='/queue/test', id=1, ack='auto')

print "Time for send message: %s", time.strftime('%H:%M:%S')
conn.send(body=' '.join(sys.argv[1:]), destination='/queue/test', headers={'AMQ_SCHEDULED_DELAY': 100000})

time.sleep(2)
conn.disconnect()

Output:

test@localhost$ python /tmp/test.py this is test
Time for send message: %s 14:03:34
Time for message receive: %s 14:03:34
received a message "this is test"

From output, seems its not working or I have to update something from ActiveMQ side.

score 4 · Accepted Answer · answered Apr 25 '17 at 20:58

4

It is enabled by setting the broker schedulerSupport attribute to true in the activemq.xml :

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

http://activemq.apache.org/delay-and-schedule-message-delivery.html

answered Apr 25 '17 at 20:58

Hassen Bennour

3,885
2
12
20

Hassen, is there any docker image with this by default settings ? I am using `activemq` docker for my deployment – Nilesh May 01 '17 at 21:33
I don't know honestly – Hassen Bennour May 02 '17 at 04:28
Thanks Hassen, will try to find one – Nilesh May 02 '17 at 16:01

AMQ_SCHEDULED_DELAY is not delaying message when use stomp.py

1 Answers1