'Invoked when all of the message has been received
:rtype: tuple(pika.frame.Method, pika.frame.Header, str)'

def _finish(self):

    content = (self._method_frame, self._header_frame, ''.join(self._body_fragments))
    self._reset()
    return content
