Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix failing unittests of pyamqp transport. (#978) 

Failing unittests were caused by commit f16df2a17630c9804a6da614443c5e862271823f in pyamqp.
This commit is contained in:
Matus Valo 2019-01-03 16:39:42 +01:00 committed by Omer Katz
parent e4dc1688a2
commit 80584c8c9b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
t/unit/transport/test_pyamqp.py
View File

@ -68,11 +68,11 @@ class test_Channel:
assert self.channel.connection is None
def test_basic_consume_registers_ack_status(self):
self.channel.wait_returns = 'my-consumer-tag'
self.channel.wait_returns = ['my-consumer-tag']
self.channel.basic_consume('foo', no_ack=True)
assert 'my-consumer-tag' in self.channel.no_ack_consumers
self.channel.wait_returns = 'other-consumer-tag'
self.channel.wait_returns = ['other-consumer-tag']
self.channel.basic_consume('bar', no_ack=False)
assert 'other-consumer-tag' not in self.channel.no_ack_consumers