You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Jiri Danek (JIRA)" <ji...@apache.org> on 2016/06/21 10:55:57 UTC
[jira] [Updated] (PROTON-1242) Sending at-most-once (presettled)
messages with a delay between them does not work with Python Messenger API
[ https://issues.apache.org/jira/browse/PROTON-1242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jiri Danek updated PROTON-1242:
-------------------------------
Attachment: slow_presettled_send_blocking.py
> 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
> Labels: messenger
> Attachments: slow_presettled_send_blocking.py
>
>
> 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: dev-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org