mq.py 文件源码

def rpush(self, msg, timeout=0):
        self._conn.rpush(self.queue, msg)
        if timeout:
            msg = "%s%s"%(msg,get_uuid())
            self.zadd(get_time()+timeout ,msg)
            return msg
        return True