Merge "Fix condition in _publish_and_retry_on_missing_exchange()"
This commit is contained in:
commit
ec5a789f22
@ -1005,7 +1005,7 @@ class Connection(object):
|
||||
# TODO(sileht): use @retrying
|
||||
# NOTE(sileht): no need to wait the application expect a response
|
||||
# before timeout is exshauted
|
||||
duration = (timeout if timeout is None
|
||||
duration = (timeout if timeout is not None
|
||||
else self.conf.rpc_response_timeout)
|
||||
|
||||
timer = rpc_common.DecayingTimer(duration=duration)
|
||||
|
Loading…
x
Reference in New Issue
Block a user