openstack/deb-python-pyngus
Code Issues Proposed changes

disable send timeout for now

Browse Source
This commit is contained in:
Kenneth Giusti 2014-01-01 12:46:20 -05:00
parent a085f61ecb
commit a3665438d3
3 changed files with 9 additions and 3 deletions

4
examples/python/rpc-client.py

@ -200,7 +200,9 @@ class MyCaller(fusion.SenderEventHandler,
msg.correlation_id = 5 # whatever...
print("sending RPC call request: %s" % str(self._method))
self._sender.send(msg, self, None, time.time() + 10)
# @todo send timeout self._sender.send(msg, self, None, time.time() +
# 10)
self._sender.send(msg, self)
# SenderEventHandler callbacks:

6
examples/python/rpc-server.py

@ -188,8 +188,10 @@ class MyReceiverLink(fusion.ReceiverEventHandler):
print(" to address=%s" % str(message.address))
print(" replying to=%s" % str(reply_to))
link = my_sender.sender_link
link.send( response, my_sender,
message, time.time() + 5.0)
# @todo send timeouts
#link.send( response, my_sender,
# message, time.time() + 5.0)
link.send(response, my_sender, message)
self._link.message_accepted(handle)

2
python/link.py

@ -148,6 +148,8 @@ class SenderLink(_Link):
"""
self._pending_sends.append( (message, delivery_callback, handle,
deadline) )
# @todo deadline not supported yet
assert not deadline, "send timeout not supported yet!"
if deadline and (self._next_deadline == 0 or
self._next_deadline > deadline):
self._next_deadline = deadline