rabbit.py 文件源码

def check_queue_message(self, message):
        q = kombu.Queue(message['queue'], channel=self.ch)
        msg = q.get(True)
        assert msg.body in message['id'],\
            "Message body is {}, expected {}".format(msg.body, message['id'])