docs: 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