Fixes incorrect exchange lock in fake driver
The exchanges lock in the fake driver was being disregarded, probably due to a typo. Closes-Bug: #1342088 Change-Id: I45261fce501a867b9253112e1608b14ed5afea26
This commit is contained in:
parent
39d1917644
commit
1cc3e5d866
@ -132,7 +132,7 @@ class FakeExchangeManager(object):
|
|||||||
def get_exchange(self, name):
|
def get_exchange(self, name):
|
||||||
if name is None:
|
if name is None:
|
||||||
name = self._default_exchange
|
name = self._default_exchange
|
||||||
while self._exchanges_lock:
|
with self._exchanges_lock:
|
||||||
return self._exchanges.setdefault(name, FakeExchange(name))
|
return self._exchanges.setdefault(name, FakeExchange(name))
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user