Configure receiver to support minimum max-frame as defined by AMQP-1.0. Verify transfer of messages larger than 512.
(self)
| 1086 | return "/".join(parts)[:size].encode("utf-8") |
| 1087 | |
| 1088 | def testMinFrame(self): |
| 1089 | """ |
| 1090 | Configure receiver to support minimum max-frame as defined by AMQP-1.0. |
| 1091 | Verify transfer of messages larger than 512. |
| 1092 | """ |
| 1093 | self.snd, self.rcv = self.link("test-link", max_frame=[0, 512]) |
| 1094 | self.c1 = self.snd.session.connection |
| 1095 | self.c2 = self.rcv.session.connection |
| 1096 | self.snd.open() |
| 1097 | self.rcv.open() |
| 1098 | self.pump() |
| 1099 | assert self.rcv.session.connection.transport.max_frame_size == 512 |
| 1100 | assert self.snd.session.connection.transport.remote_max_frame_size == 512 |
| 1101 | |
| 1102 | self.rcv.flow(1) |
| 1103 | self.snd.delivery("tag") |
| 1104 | msg = self.message(513) |
| 1105 | n = self.snd.send(msg) |
| 1106 | assert n == len(msg) |
| 1107 | assert self.snd.advance() |
| 1108 | |
| 1109 | self.pump() |
| 1110 | |
| 1111 | binary = self.rcv.recv(513) |
| 1112 | assert binary == msg |
| 1113 | |
| 1114 | binary = self.rcv.recv(1024) |
| 1115 | assert binary is None |
| 1116 | |
| 1117 | def testOddFrame(self): |
| 1118 | """ |