Jiri Danek created PROTON-1242:
----------------------------------
Summary: Sending at-most-once (presettled) messages with a delay
between them does not work with Python Messenger API
Key: PROTON-1242
URL: https://issues.apache.org/jira/browse/PROTON-1242
Project: Qpid Proton
Issue Type: Bug
Components: python-binding
Affects Versions: 0.13.0
Environment: Red Hat Enterprise Linux 6.8 64bit, dispatch-router 0.6.0
Reporter: Jiri Danek
Messenger blocking API should work in combination with calls to
{{time.sleep()}}. For example, if I wish to send certain number of messages
with 0.5s delay between each, I should be able to write
{code}
messages = 5
host, path = address.split('/')
conn = BlockingConnection(host)
sender = conn.create_sender(path, options=AtMostOnce())
for i in range(messages):
sender.send(Message(body="message %d" % i));
time.sleep(0.5)
{code}
The code above does not work. I tried sending over Qpid Dispatch Router and
receiving with the simple_recv.py example and all five messages arrived at
once, after approx. 2 seconds of waiting.
If I leave out {{options=AtMostOnce()}}, then the code above works as expected.
Steps to reproduce:
{{python qpid-proton/examples/python/simple_recv.py -a
172.28.128.251/myaddress}}
{{python slow_presettled_send_blocking.py -a 172.28.128.251/myaddress -m 5}}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
