(self, name)
| 72 | assert reencoded == encoded, "Value mismatch: %s != %s" % (reencoded, encoded) |
| 73 | |
| 74 | def decode_message_file(self, name): |
| 75 | self.message.decode(self.get_data(name)) |
| 76 | body = self.message.body |
| 77 | if str(type(body)) == "<type 'org.apache.qpid.proton.amqp.Binary'>": |
| 78 | body = body.array.tostring() |
| 79 | self.decode_data(body) |
| 80 | |
| 81 | def assert_next(self, type, value): |
| 82 | next_type = self.data.next() |