def _read_msg(self, method_frame, with_consumer_tag=False,
                  with_message_count=False):
        header_frame, body = self._reap_msg_frames(method_frame)

        if with_consumer_tag:
            consumer_tag = method_frame.args.read_shortstr()
        delivery_tag = method_frame.args.read_longlong()
        redelivered = method_frame.args.read_bit()
        exchange = method_frame.args.read_shortstr()
        routing_key = method_frame.args.read_shortstr()
        if with_message_count:
            message_count = method_frame.args.read_long()

        delivery_info = {
            'channel': self.channel,
            'delivery_tag': delivery_tag,
            'redelivered': redelivered,
            'exchange': exchange,
            'routing_key': routing_key,
        }
        if with_consumer_tag:
            delivery_info['consumer_tag'] = consumer_tag
        if with_message_count:
            delivery_info['message_count'] = message_count

        return Message(body=body, delivery_info=delivery_info,
                       **header_frame.properties)
returns the number of unread messages for the given user but does not
dataset/ETHPy150Open agoragames/haigha/haigha/classes/basic_class.py/BasicClass._read_msg--crossover with--dataset/ETHPy150Open amarandon/smeuhsocial/apps/messages/models.py/inbox_count_for