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