Configure receiver to support minimum max-frame as defined by AMQP-1.0. Verify transfer of messages larger than 512.
(self)
| 1008 | return "/".join(parts)[:size].encode("utf-8") |
| 1009 | |
| 1010 | def testMinFrame(self): |
| 1011 | """ |
| 1012 | Configure receiver to support minimum max-frame as defined by AMQP-1.0. |
| 1013 | Verify transfer of messages larger than 512. |
| 1014 | """ |
| 1015 | self.snd, self.rcv = self.link("test-link", max_frame=[0,512]) |
| 1016 | self.c1 = self.snd.session.connection |
| 1017 | self.c2 = self.rcv.session.connection |
| 1018 | self.snd.open() |
| 1019 | self.rcv.open() |
| 1020 | self.pump() |
| 1021 | assert self.rcv.session.connection.transport.max_frame_size == 512 |
| 1022 | assert self.snd.session.connection.transport.remote_max_frame_size == 512 |
| 1023 | |
| 1024 | self.rcv.flow(1) |
| 1025 | self.snd.delivery("tag") |
| 1026 | msg = self.message(513) |
| 1027 | n = self.snd.send(msg) |
| 1028 | assert n == len(msg) |
| 1029 | assert self.snd.advance() |
| 1030 | |
| 1031 | self.pump() |
| 1032 | |
| 1033 | binary = self.rcv.recv(513) |
| 1034 | assert binary == msg |
| 1035 | |
| 1036 | binary = self.rcv.recv(1024) |
| 1037 | assert binary == None |
| 1038 | |
| 1039 | def testOddFrame(self): |
| 1040 | """ |