summaryrefslogtreecommitdiff
path: root/t/integration/test_integration.py
diff options
context:
space:
mode:
Diffstat (limited to 't/integration/test_integration.py')
-rw-r--r--t/integration/test_integration.py6
1 files changed, 4 insertions, 2 deletions
diff --git a/t/integration/test_integration.py b/t/integration/test_integration.py
index 9320d07..57d5e62 100644
--- a/t/integration/test_integration.py
+++ b/t/integration/test_integration.py
@@ -415,7 +415,7 @@ class test_channel:
)
frame_writer_mock = frame_writer_cls_mock()
frame_writer_mock.reset_mock()
- ch.basic_consume('my_queue', callback=callback_mock)
+ ret = ch.basic_consume('my_queue', callback=callback_mock)
frame_writer_mock.assert_called_once_with(
1, 1, spec.Basic.Consume,
dumps(
@@ -425,6 +425,7 @@ class test_channel:
None
)
assert ch.callbacks[consumer_tag] == callback_mock
+ assert ret == 'amq.ctag-PCmzXGkhCw_v0Zq7jXyvkg'
def test_consume_with_consumer_tag(self):
# Test verifing starting consuming with specified consumer_tag
@@ -444,7 +445,7 @@ class test_channel:
)
frame_writer_mock = frame_writer_cls_mock()
frame_writer_mock.reset_mock()
- ch.basic_consume(
+ ret = ch.basic_consume(
'my_queue', callback=callback_mock, consumer_tag='my_tag'
)
frame_writer_mock.assert_called_once_with(
@@ -459,6 +460,7 @@ class test_channel:
None
)
assert ch.callbacks['my_tag'] == callback_mock
+ assert ret == 'my_tag'
def test_queue_declare(self):
# Test verifying declaring queue