From c1fe574f64e5afc09c22ff5c4f655a0168d8629f Mon Sep 17 00:00:00 2001 From: "Kian-Meng, Ang" Date: Sat, 6 Nov 2021 13:00:29 +0800 Subject: Fix typos --- t/integration/test_integration.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) (limited to 't/integration/test_integration.py') diff --git a/t/integration/test_integration.py b/t/integration/test_integration.py index 951bf9c..1ce3851 100644 --- a/t/integration/test_integration.py +++ b/t/integration/test_integration.py @@ -114,7 +114,7 @@ def build_frame_type_3(channel, body): class DataComparator: # Comparator used for asserting serialized data. It can be used - # in cases when direct comparision of bytestream cannot be used + # in cases when direct comparison of bytestream cannot be used # (mainly cases of Table type where order of items can vary) def __init__(self, argsig, items): self.argsig = argsig @@ -367,7 +367,7 @@ class test_connection: @patch('amqp.Connection._on_blocked') def test_connecion_ignore_methods_during_close(self, on_blocked_mock): # Test checking that py-amqp will discard any received methods - # except Close and Close-OK after sending Connecion.Close method + # except Close and Close-OK after sending Connection.Close method # to server. frame_writer_cls_mock = Mock() frame_writer_mock = frame_writer_cls_mock() @@ -601,7 +601,7 @@ class test_channel: callback_mock.assert_called_once() def test_basic_publish(self): - # Test verifing publishing message. + # Test verifying publishing message. frame_writer_cls_mock = Mock() conn = Connection(frame_writer=frame_writer_cls_mock) with patch.object(conn, 'Transport') as transport_mock: @@ -621,7 +621,7 @@ class test_channel: ) def test_consume_no_consumer_tag(self): - # Test verifing starting consuming without specified consumer_tag + # Test verifying starting consuming without specified consumer_tag callback_mock = Mock() frame_writer_cls_mock = Mock() conn = Connection(frame_writer=frame_writer_cls_mock) @@ -652,7 +652,7 @@ class test_channel: assert ret == 'amq.ctag-PCmzXGkhCw_v0Zq7jXyvkg' def test_consume_with_consumer_tag(self): - # Test verifing starting consuming with specified consumer_tag + # Test verifying starting consuming with specified consumer_tag callback_mock = Mock() frame_writer_cls_mock = Mock() conn = Connection(frame_writer=frame_writer_cls_mock) @@ -745,7 +745,7 @@ class test_channel: assert excinfo.value.method_sig == spec.Exchange.Declare # Client is sending to broker: # 1. Exchange Declare - # 2. Connection.CloseOk as reply to received Connecton.Close + # 2. Connection.CloseOk as reply to received Connection.Close frame_writer_calls = [ call( 1, 1, spec.Queue.Declare, @@ -1024,7 +1024,7 @@ class test_channel: assert excinfo.value.method_sig == spec.Exchange.Declare # Client is sending to broker: # 1. Exchange Declare - # 2. Connection.CloseOk as reply to received Connecton.Close + # 2. Connection.CloseOk as reply to received Connection.Close frame_writer_calls = [ call( 1, 1, spec.Exchange.Declare, -- cgit v1.2.1