# -*- encoding: utf-8 -*- import time import unittest from pamqp import body, frame, header, PYTHON3, specification if PYTHON3: long = int basestring = str unicode = None class DemarshalingTests(unittest.TestCase): def test_protocol_header(self): # Decode the frame and validate lengths frame_data = b'AMQP\x00\x00\t\x01' consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 8, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 8)) self.assertEqual( channel, 0, 'Channel number did not match expectation: %i, %i' % (channel, 0)) # Validate the frame name self.assertEqual(frame_obj.name, 'ProtocolHeader', ('Frame was of wrong type, expected ProtocolHeader, ' 'received %s' % frame_obj.name)) self.assertEqual((frame_obj.major_version, frame_obj.minor_version, frame_obj.revision), (0, 9, 1), 'Protocol version is incorrect') def test_heartbeat(self): frame_data = b'\x08\x00\x00\x00\x00\x00\x00\xce' consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 8, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 8)) self.assertEqual( channel, 0, 'Channel number did not match expectation: %i, %i' % (channel, 0)) # Validate the frame name self.assertEqual(frame_obj.name, 'Heartbeat', ('Frame was of wrong type, expected Heartbeat, ' 'received %s' % frame_obj.name)) def test_basic_ack(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\r\x00<\x00P\x00\x00\x00\x00' b'\x00\x00\x00\x01\x00\xce') expectation = {'multiple': False, 'delivery_tag': 1} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 21, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 21)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.Ack', ('Frame was of wrong type, expected Basic.Ack, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_cancel(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\r\x00<\x00\x1e\x07ctag1.0\x00' b'\xce') expectation = {'consumer_tag': 'ctag1.0', 'nowait': False} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 21, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 21)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.Cancel', ('Frame was of wrong type, expected Basic.Cancel, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_cancelok(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x0c\x00<\x00\x1f\x07ctag1.0' b'\xce') expectation = {'consumer_tag': 'ctag1.0'} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 20, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 20)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.CancelOk', ('Frame was of wrong type, expected Basic.CancelOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_consume(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x18\x00<\x00\x14\x00\x00\x04' b'test\x07ctag1.0\x00\x00\x00\x00\x00\xce') expectation = { 'exclusive': False, 'nowait': False, 'no_local': False, 'consumer_tag': 'ctag1.0', 'queue': 'test', 'arguments': {}, 'ticket': 0, 'no_ack': False } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 32, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 32)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.Consume', ('Frame was of wrong type, expected Basic.Consume, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_consumeok(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x0c\x00<\x00\x15\x07ctag1.0' b'\xce') expectation = {'consumer_tag': 'ctag1.0'} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 20, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 20)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.ConsumeOk', ('Frame was of wrong type, expected Basic.ConsumeOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_deliver(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x1b\x00<\x00<\x07ctag1.0' b'\x00\x00\x00\x00\x00\x00\x00\x01\x00\x00\x04test\xce') expectation = { 'consumer_tag': 'ctag1.0', 'delivery_tag': 1, 'redelivered': False, 'exchange': '', 'routing_key': 'test' } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 35, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 35)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.Deliver', ('Frame was of wrong type, expected Basic.Deliver, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_get(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x0c\x00<\x00F\x00\x00\x04' b'test\x00\xce') expectation = {'queue': 'test', 'ticket': 0, 'no_ack': False} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 20, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 20)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.Get', ('Frame was of wrong type, expected Basic.Get, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_getempty(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x05\x00<\x00H\x00\xce' expectation = {'cluster_id': ''} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 13, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 13)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.GetEmpty', ('Frame was of wrong type, expected Basic.GetEmpty, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_getok(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x17\x00<\x00G\x00\x00\x00\x00' b'\x00\x00\x00\x10\x00\x00\x04test\x00\x00\x12\x06\xce') expectation = { 'message_count': 4614, 'redelivered': False, 'routing_key': 'test', 'delivery_tag': 16, 'exchange': '' } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 31, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 31)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.GetOk', ('Frame was of wrong type, expected Basic.GetOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_nack(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\r\x00<\x00x\x00\x00\x00\x00' b'\x00\x00\x00\x01\x00\xce') expectation = {'requeue': False, 'multiple': False, 'delivery_tag': 1} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 21, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 21)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.Nack', ('Frame was of wrong type, expected Basic.Nack, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_content_header(self): result = frame.unmarshal(frame.marshal(header.ContentHeader(0, 100), 1)) self.assertEqual(result[2].body_size, 100) def test_content_body(self): result = frame.unmarshal(frame.marshal(body.ContentBody(b'TEST'), 1)) self.assertEqual(len(result[2]), 4) def test_basic_properties(self): encoded_properties = (b'\xff\xfc\x10application/json\x04gzip\x00\x00' b'\x00\x1d\x03bazS\x00\x00\x00\x08Test \xe2\x9c' b'\x88\x03fooS\x00\x00\x00\x03bar\x01\x00$a5304' b'5ef-f174-4621-9ff2-ac0b8fbe6e4a\x12unmarshali' b'ng_tests\n1345274026$746a1902-39dc-47cf-9471-' b'9feecda35660\x00\x00\x00\x00Pj\xb9\x07\x08uni' b'ttest\x04pika\x18frame_unmarshaling_tests\x00') properties = { 'content_type': 'application/json', 'content_encoding': 'gzip', 'headers': { 'foo': b'bar', 'baz': b'Test \xe2\x9c\x88' }, 'delivery_mode': 1, 'priority': 0, 'correlation_id': 'a53045ef-f174-4621-9ff2-ac0b8fbe6e4a', 'reply_to': 'unmarshaling_tests', 'expiration': '1345274026', 'message_id': '746a1902-39dc-47cf-9471-9feecda35660', 'timestamp': time.struct_time((2012, 10, 2, 9, 51, 3, 1, 276, 0)), 'message_type': 'unittest', 'user_id': 'pika', 'app_id': 'frame_unmarshaling_tests', 'cluster_id': '' } obj = header.ContentHeader() offset, flags = obj._get_flags(encoded_properties) # Decode the frame and validate lengths obj = specification.Basic.Properties() obj.unmarshal(flags, encoded_properties[offset:]) for key in properties: self.assertEqual( getattr(obj, key), properties[key], '%r value of %r did not match expectation of %r' % (key, getattr(obj, key), properties[key])) def test_basic_publish(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\r\x00<\x00(\x00\x00\x00' b'\x04test\x00\xce') expectation = { 'ticket': 0, 'mandatory': False, 'routing_key': 'test', 'immediate': False, 'exchange': '' } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 21, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 21)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.Publish', ('Frame was of wrong type, expected Basic.Publish, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_qos(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x0b\x00<\x00\n\x00\x00\x00' b'\x00\x00\x01\x00\xce') expectation = { 'prefetch_count': 1, 'prefetch_size': 0, 'global_': False } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 19, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 19)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.Qos', ('Frame was of wrong type, expected Basic.Qos, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_qosok(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x00<\x00\x0b\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.QosOk', ('Frame was of wrong type, expected Basic.QosOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_recover(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x05\x00<\x00n\x00\xce' expectation = {'requeue': False} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 13, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 13)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.Recover', ('Frame was of wrong type, expected Basic.Recover, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_recoverasync(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x05\x00<\x00d\x00\xce' expectation = {'requeue': False} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 13, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 13)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual( frame_obj.name, 'Basic.RecoverAsync', ('Frame was of wrong type, expected Basic.RecoverAsync, ' 'received %s' % frame_obj.name)) self.assertDictEqual(dict(frame_obj), expectation) def test_basic_recoverok(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x00<\x00o\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.RecoverOk', ('Frame was of wrong type, expected Basic.RecoverOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_reject(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\r\x00<\x00Z\x00\x00\x00\x00' b'\x00\x00\x00\x10\x01\xce') expectation = {'requeue': True, 'delivery_tag': 16} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 21, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 21)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.Reject', ('Frame was of wrong type, expected Basic.Reject, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_basic_return(self): frame_data = (b'\x01\x00\x01\x00\x00\x00"\x00<\x002\x00\xc8\x0f' b'Normal shutdown\x03foo\x07foo.bar\xce') expectation = { 'reply_code': 200, 'reply_text': 'Normal shutdown', 'routing_key': 'foo.bar', 'exchange': 'foo' } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 42, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 42)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Basic.Return', ('Frame was of wrong type, expected Basic.Return, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_channel_close(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x1a\x00\x14\x00(\x00\xc8\x0f' b'Normal shutdown\x00\x00\x00\x00\xce') expectation = { 'class_id': 0, 'method_id': 0, 'reply_code': 200, 'reply_text': 'Normal shutdown' } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 34, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 34)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Channel.Close', ('Frame was of wrong type, expected Channel.Close, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_channel_closeok(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x00\x14\x00)\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Channel.CloseOk', ('Frame was of wrong type, expected Channel.CloseOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_channel_flow(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x05\x00\x14\x00\x14\x01\xce' expectation = {'active': True} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 13, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 13)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Channel.Flow', ('Frame was of wrong type, expected Channel.Flow, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_channel_flowok(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x05\x00\x14\x00\x15\x01\xce' expectation = {'active': True} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 13, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 13)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Channel.FlowOk', ('Frame was of wrong type, expected Channel.FlowOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_channel_open(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x05\x00\x14\x00\n\x00\xce' expectation = {'out_of_band': ''} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 13, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 13)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Channel.Open', ('Frame was of wrong type, expected Channel.Open, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_channel_openok(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x08\x00\x14\x00\x0b\x00\x00' b'\x00\x00\xce') expectation = {'channel_id': b''} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 16, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 16)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Channel.OpenOk', ('Frame was of wrong type, expected Channel.OpenOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_confirm_select(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x05\x00U\x00\n\x00\xce' expectation = {'nowait': False} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 13, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 13)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Confirm.Select', ('Frame was of wrong type, expected Confirm.Select, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_confirm_selectok(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x00U\x00\x0b\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Confirm.SelectOk', ('Frame was of wrong type, expected ' 'Confirm.SelectOk, received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_connection_close(self): frame_data = (b'\x01\x00\x00\x00\x00\x00\x1a\x00\n\x002\x00\xc8\x0f' b'Normal shutdown\x00\x00\x00\x00\xce') expectation = { 'class_id': 0, 'method_id': 0, 'reply_code': 200, 'reply_text': 'Normal shutdown' } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 34, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 34)) self.assertEqual( channel, 0, 'Channel number did not match expectation: %i, %i' % (channel, 0)) # Validate the frame name self.assertEqual(frame_obj.name, 'Connection.Close', ('Frame was of wrong type, expected ' 'Connection.Close, received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_connection_closeok(self): frame_data = b'\x01\x00\x00\x00\x00\x00\x04\x00\n\x003\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 0, 'Channel number did not match expectation: %i, %i' % (channel, 0)) # Validate the frame name self.assertEqual(frame_obj.name, 'Connection.CloseOk', ('Frame was of wrong type, expected ' 'Connection.CloseOk, received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_connection_open(self): frame_data = (b'\x01\x00\x00\x00\x00\x00\x08\x00\n\x00(\x01/\x00' b'\x01\xce') expectation = {'insist': True, 'capabilities': '', 'virtual_host': '/'} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 16, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 16)) self.assertEqual( channel, 0, 'Channel number did not match expectation: %i, %i' % (channel, 0)) # Validate the frame name self.assertEqual(frame_obj.name, 'Connection.Open', ('Frame was of wrong type, expected Connection.Open, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_connection_openok(self): frame_data = b'\x01\x00\x00\x00\x00\x00\x05\x00\n\x00)\x00\xce' expectation = {'known_hosts': ''} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 13, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 13)) self.assertEqual( channel, 0, 'Channel number did not match expectation: %i, %i' % (channel, 0)) # Validate the frame name self.assertEqual(frame_obj.name, 'Connection.OpenOk', ('Frame was of wrong type, expected ' 'Connection.OpenOk, received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_connection_secure(self): frame_data = (b'\x01\x00\x00\x00\x00\x00\x08\x00\n\x00\x14\x00\x00' b'\x00\x00\xce') expectation = {'challenge': b''} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 16, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 16)) self.assertEqual( channel, 0, 'Channel number did not match expectation: %i, %i' % (channel, 0)) # Validate the frame name self.assertEqual(frame_obj.name, 'Connection.Secure', ('Frame was of wrong type, expected ' 'Connection.Secure, received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_connection_secureok(self): frame_data = (b'\x01\x00\x00\x00\x00\x00\x08\x00\n\x00\x15\x00\x00' b'\x00\x00\xce') expectation = {'response': b''} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 16, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 16)) self.assertEqual( channel, 0, 'Channel number did not match expectation: %i, %i' % (channel, 0)) # Validate the frame name self.assertEqual(frame_obj.name, 'Connection.SecureOk', ('Frame was of wrong type, expected ' 'Connection.SecureOk, received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_connection_start(self): frame_data = (b'\x01\x00\x00\x00\x00\x01G\x00\n\x00\n\x00\t' b'\x00\x00\x01"\x0ccapabilitiesF\x00\x00\x00X' b'\x12publisher_confirmst\x01\x1aexchange_exc' b'hange_bindingst\x01\nbasic.nackt\x01\x16con' b'sumer_cancel_notifyt\x01\tcopyrightS\x00' b'\x00\x00$Copyright (C) 2007-2011 VMware, I' b'nc.\x0binformationS\x00\x00\x005Licensed u' b'nder the MPL. See http://www.rabbitmq.com' b'/\x08platformS\x00\x00\x00\nErlang/OTP\x07' b'productS\x00\x00\x00\x08RabbitMQ\x07versio' b'nS\x00\x00\x00\x052.6.1\x00\x00\x00\x0ePLA' b'IN AMQPLAIN\x00\x00\x00\x05en_US\xce') expectation = { 'server_properties': { 'information': (b'Licensed under the MPL. ' b'See http://www.rabbitmq.com/'), 'product': b'RabbitMQ', 'copyright': b'Copyright (C) 2007-2011 VMware, Inc.', 'capabilities': { 'exchange_exchange_bindings': True, 'consumer_cancel_notify': True, 'publisher_confirms': True, 'basic.nack': True }, 'platform': b'Erlang/OTP', 'version': b'2.6.1' }, 'version_minor': 9, 'mechanisms': b'PLAIN AMQPLAIN', 'locales': b'en_US', 'version_major': 0 } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 335, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 335)) self.assertEqual( channel, 0, 'Channel number did not match expectation: %i, %i' % (channel, 0)) # Validate the frame name self.assertEqual(frame_obj.name, 'Connection.Start', ('Frame was of wrong type, expected ' 'Connection.Start, received %s' % frame_obj.name)) self.maxDiff = 32768 # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_connection_startok(self): frame_data = (b'\x01\x00\x00\x00\x00\x00\xf4\x00\n\x00\x0b' b'\x00\x00\x00\xd0\x08platformS\x00\x00\x00' b'\x0cPython 2.7.1\x07productS\x00\x00\x00' b'\x1aPika Python Client Library\x07versionS' b'\x00\x00\x00\n0.9.6-pre0\x0ccapabilitiesF' b'\x00\x00\x00;\x16consumer_cancel_notifyt' b'\x01\x12publisher_confirmst\x01\nbasic.nack' b't\x01\x0binformationS\x00\x00\x00\x1aSee ' b'http://pika.github.com\x05PLAIN\x00\x00' b'\x00\x0c\x00guest\x00guest\x05en_US\xce') expectation = { 'locale': 'en_US', 'mechanism': 'PLAIN', 'client_properties': { 'platform': b'Python 2.7.1', 'product': b'Pika Python Client Library', 'version': b'0.9.6-pre0', 'capabilities': { 'consumer_cancel_notify': True, 'publisher_confirms': True, 'basic.nack': True }, 'information': b'See http://pika.github.com' }, 'response': b'\x00guest\x00guest' } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 252, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 252)) self.assertEqual( channel, 0, 'Channel number did not match expectation: %i, %i' % (channel, 0)) # Validate the frame name self.assertEqual(frame_obj.name, 'Connection.StartOk', ('Frame was of wrong type, expected ' 'Connection.StartOk, received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_connection_tune(self): frame_data = (b'\x01\x00\x00\x00\x00\x00\x0c\x00\n\x00\x1e\x00\x00' b'\x00\x02\x00\x00\x00\x00\xce') expectation = {'frame_max': 131072, 'channel_max': 0, 'heartbeat': 0} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 20, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 20)) self.assertEqual( channel, 0, 'Channel number did not match expectation: %i, %i' % (channel, 0)) # Validate the frame name self.assertEqual(frame_obj.name, 'Connection.Tune', ('Frame was of wrong type, expected Connection.Tune, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_connection_tuneok(self): frame_data = (b'\x01\x00\x00\x00\x00\x00\x0c\x00\n\x00\x1f\x00\x00' b'\x00\x02\x00\x00\x00\x00\xce') expectation = {'frame_max': 131072, 'channel_max': 0, 'heartbeat': 0} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 20, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 20)) self.assertEqual( channel, 0, 'Channel number did not match expectation: %i, %i' % (channel, 0)) # Validate the frame name self.assertEqual(frame_obj.name, 'Connection.TuneOk', ('Frame was of wrong type, expected ' 'Connection.TuneOk, received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_content_body_frame(self): frame_data = (b'\x03\x00\x00\x00\x00\x00"Hello World #0:1316899165.' b'75516605\xce') expectation = b'Hello World #0:1316899165.75516605' # Decode the frame and validate lengths consumed, channel, data = frame.unmarshal(frame_data) self.assertEqual( consumed, 42, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 42)) self.assertEqual( channel, 0, 'Channel number did not match expectation: %i, %i' % (channel, 0)) # Validate the unmarshaled data matches the expectation self.assertEqual(data.value, expectation) def test_exchange_bind(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x15\x00(\x00\x1e\x00\x00' b'\x00\x00\x07foo.bar\x00\x00\x00\x00\x00\xce') expectation = { 'arguments': {}, 'source': '', 'ticket': 0, 'destination': '', 'nowait': False, 'routing_key': 'foo.bar' } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 29, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 29)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Exchange.Bind', ('Frame was of wrong type, expected Exchange.Bind, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_exchange_bindok(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x00(\x00\x1f\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Exchange.BindOk', ('Frame was of wrong type, expected Exchange.BindOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_exchange_declare(self): frame_data = (b'\x01\x00\x01\x00\x00\x00%\x00(\x00\n\x00\x00\x12pika_' b'test_exchange\x06direct\x00\x00\x00\x00\x00\xce') expectation = { 'nowait': False, 'exchange': 'pika_test_exchange', 'durable': False, 'passive': False, 'internal': False, 'arguments': {}, 'ticket': 0, 'exchange_type': 'direct', 'auto_delete': False } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 45, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 45)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Exchange.Declare', ('Frame was of wrong type, expected ' 'Exchange.Declare, received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_exchange_declareok(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x00(\x00\x0b\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Exchange.DeclareOk', ('Frame was of wrong type, expected Exchange.' 'DeclareOk, received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_exchange_delete(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x1a\x00(\x00\x14\x00\x00\x12' b'pika_test_exchange\x00\xce') expectation = { 'ticket': 0, 'if_unused': False, 'nowait': False, 'exchange': 'pika_test_exchange' } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 34, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 34)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Exchange.Delete', ('Frame was of wrong type, expected Exchange.Delete, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_exchange_deleteok(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x00(\x00\x15\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Exchange.DeleteOk', ('Frame was of wrong type, expected ' 'Exchange.DeleteOk, received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_exchange_unbind(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x15\x00(\x00(\x00\x00\x00' b'\x00\x07foo.bar\x00\x00\x00\x00\x00\xce') expectation = { 'arguments': {}, 'source': '', 'ticket': 0, 'destination': '', 'nowait': False, 'routing_key': 'foo.bar' } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 29, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 29)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Exchange.Unbind', ('Frame was of wrong type, expected Exchange.Unbind, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_exchange_unbindok(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x00(\x003\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Exchange.UnbindOk', ('Frame was of wrong type, expected ' 'Exchange.UnbindOk, received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_queue_bind(self): frame_data = (b'\x01\x00\x01\x00\x00\x00?\x002\x00\x14\x00' b'\x00\x0fpika_test_queue\x12pika_test_excha' b'nge\x10test_routing_key\x00\x00\x00\x00\x00' b'\xce') expectation = { 'nowait': False, 'exchange': 'pika_test_exchange', 'routing_key': 'test_routing_key', 'queue': 'pika_test_queue', 'arguments': {}, 'ticket': 0 } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 71, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 71)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Queue.Bind', ('Frame was of wrong type, expected Queue.Bind, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_queue_bindok(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x002\x00\x15\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Queue.BindOk', ('Frame was of wrong type, expected Queue.BindOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_queue_declare(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x10\x002\x00\n\x00\x00\x04' b'test\x02\x00\x00\x00\x00\xce') expectation = { 'passive': False, 'nowait': False, 'exclusive': False, 'durable': True, 'queue': 'test', 'arguments': {}, 'ticket': 0, 'auto_delete': False } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 24, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 24)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Queue.Declare', ('Frame was of wrong type, expected Queue.Declare, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_queue_declareok(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x11\x002\x00\x0b\x04test' b'\x00\x00\x12\x07\x00\x00\x00\x00\xce') expectation = { 'queue': 'test', 'message_count': 4615, 'consumer_count': 0 } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 25, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 25)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Queue.DeclareOk', ('Frame was of wrong type, expected Queue.DeclareOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_queue_delete(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x17\x002\x00(\x00\x00\x0f' b'pika_test_queue\x00\xce') expectation = { 'queue': 'pika_test_queue', 'ticket': 0, 'if_empty': False, 'nowait': False, 'if_unused': False } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 31, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 31)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Queue.Delete', ('Frame was of wrong type, expected Queue.Delete, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_queue_deleteok(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x08\x002\x00)\x00\x00\x00' b'\x00\xce') expectation = {'message_count': 0} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 16, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 16)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Queue.DeleteOk', ('Frame was of wrong type, expected Queue.DeleteOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_queue_purge(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x0c\x002\x00\x1e\x00\x00' b'\x04test\x00\xce') expectation = {'queue': 'test', 'ticket': 0, 'nowait': False} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 20, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 20)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Queue.Purge', ('Frame was of wrong type, expected Queue.Purge, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_queue_purgeok(self): frame_data = (b'\x01\x00\x01\x00\x00\x00\x08\x002\x00\x1f\x00\x00\x00' b'\x01\xce') expectation = {'message_count': 1} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 16, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 16)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Queue.PurgeOk', ('Frame was of wrong type, expected Queue.PurgeOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_queue_unbind(self): frame_data = (b'\x01\x00\x01\x00\x00\x00>\x002\x002\x00\x00\x0f' b'pika_test_queue\x12pika_test_exchange\x10test_routing' b'_key\x00\x00\x00\x00\xce') expectation = { 'queue': 'pika_test_queue', 'arguments': {}, 'ticket': 0, 'routing_key': 'test_routing_key', 'exchange': 'pika_test_exchange' } # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 70, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 70)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Queue.Unbind', ('Frame was of wrong type, expected Queue.Unbind, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_queue_unbindok(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x002\x003\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Queue.UnbindOk', ('Frame was of wrong type, expected Queue.UnbindOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_tx_commit(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x00Z\x00\x14\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Tx.Commit', ('Frame was of wrong type, expected Tx.Commit, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_tx_commitok(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x00Z\x00\x15\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Tx.CommitOk', ('Frame was of wrong type, expected Tx.CommitOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_tx_rollback(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x00Z\x00\x1e\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Tx.Rollback', ('Frame was of wrong type, expected Tx.Rollback, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_tx_rollbackok(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x00Z\x00\x1f\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Tx.RollbackOk', ('Frame was of wrong type, expected Tx.RollbackOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_tx_select(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x00Z\x00\n\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Tx.Select', ('Frame was of wrong type, expected Tx.Select, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation) def test_tx_selectok(self): frame_data = b'\x01\x00\x01\x00\x00\x00\x04\x00Z\x00\x0b\xce' expectation = {} # Decode the frame and validate lengths consumed, channel, frame_obj = frame.unmarshal(frame_data) self.assertEqual( consumed, 12, 'Bytes consumed did not match expectation: %i, %i' % (consumed, 12)) self.assertEqual( channel, 1, 'Channel number did not match expectation: %i, %i' % (channel, 1)) # Validate the frame name self.assertEqual(frame_obj.name, 'Tx.SelectOk', ('Frame was of wrong type, expected Tx.SelectOk, ' 'received %s' % frame_obj.name)) # Validate the unmarshaled data matches the expectation self.assertDictEqual(dict(frame_obj), expectation)