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.py14
1 files changed, 7 insertions, 7 deletions
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,