我正在docker容器上运行ActiveMQ
服务器。在
我正在使用AMQ_SCHEDULED_DELAY
头来延迟消息。在
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()
输出:
^{pr2}$从输出来看,它似乎不起作用,或者我必须从ActiveMQ端更新一些东西。在
在中,通过将broker schedulerSupport属性设置为true来启用它活动MQ.xml公司名称:
http://activemq.apache.org/delay-and-schedule-message-delivery.html
相关问题 更多 >
编程相关推荐