def _process_content_body(self, channel, payload):
        """
        Process Content Body frames

        """
        partial = self.partial_messages[channel]
        partial.add_payload(payload)
        if partial.complete:
            #
            # Stick the message in the queue and go back to
            # waiting for method frames
            #
            self.queue.put((channel, partial.method_sig, partial.args, partial.msg))
            del self.partial_messages[channel]
            self.expected_types[channel] = 1
def _process_content_body ( self , channel , payload ) : partial = self . partial_messages [ channel ] partial . add_payload ( payload ) if partial . complete : self . queue . put ( ( channel , partial . method_sig , partial . args , partial . msg ) ) del self . partial_messages [ channel ] self . expected_types [ channel ] = 1
Process Content Body frames