Hi all,
I’m having a bit of trouble using the scheduled delivery function in Artemis
(2.6.4) in an AMQP protocol, via the Qpid-Proton Python library.
From what I can tell, this should work (from the simple sender example in the
Proton repo)
from datetime import datetime as dt, timezone as tc
deltime = int(dt.utcnow().replace(tzinfo=tz.utc).timestamp() * 1000.0)
+ 120000
anns = {'x-opt-delivery-time' : deltime}
while event.sender.credit and self.sent < self.total:
msg = Message(id=(self.ts * 1000000 + self.sent+1),
body={'sequence':(self.sent+1)}, annotations=anns)
event.sender.send(msg)
self.sent += 1
The messages are properly queued, but delivered instantly.
I’m guessing that there’s some property which needs to be set at the broker
level, but not quite sure what.
No doubt there’s some obvious setting that I’m missing, so would appreciate the
help.
Cheers,
Neil
