in uamqp/message.py [0:0]
def _parse_message_body(self, message):
"""Parse a message received from an AMQP service.
:param message: The received C message.
:type message: uamqp.c_uamqp.cMessage
"""
_logger.debug("Parsing received message %r.", self.delivery_no)
self._message = message
delivery_tag = self._message.delivery_tag
if delivery_tag:
self.delivery_tag = delivery_tag.value
body_type = message.body_type
if body_type == c_uamqp.MessageBodyType.NoneType:
self._body = None
elif body_type == c_uamqp.MessageBodyType.DataType:
self._body = DataBody(self._message)
elif body_type == c_uamqp.MessageBodyType.SequenceType:
self._body = SequenceBody(self._message)
else:
self._body = ValueBody(self._message)
self._need_further_parse = True