mq.py 文件源码

def zrangebyscore(self):
        res = self._conn.zrangebyscore(self.ack_queue , 0, get_time())
        if not isinstance(res,list):
            res = [res]
        return res

#    def sadd(self, queue, value):
#        return self._conn.sadd(queue, value)
#
#    def spop(self, queue):
#        msg = self._conn.spop(queue)
#        return msg if msg else msg
#
#    def srem(self, queue, value):
#        return self._conn.srem(queue, value)