openstack/oslo.messaging
Code Issues Proposed changes

Fix condition in _publish_and_retry_on_missing_exchange()

Browse Source 
The current condition logic in _publish_and_retry_on_missing_exchange()
replaces passed `timeout` value with `rpc_response_timeout` config value.

This patch fix it.

Change-Id: I451cd2b5da78a3d7011466dfb14669aa1dcf1d5c
This commit is contained in:
Victor Sergeyev 2015-05-29 17:27:36 +03:00
parent baddce34a2
commit 5181361f7c
1 changed files with 1 additions and 1 deletions

2
oslo_messaging/_drivers/impl_rabbit.py

@ -1001,7 +1001,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)