(self, redis_client, port, db)
:param redis_client: Redis client
        :param db: Redis Database index
        :param port: Redis port
        :return: Redis queue length
:param redis_client: Redis client
        :param db: Redis Database index
        :param port: Redis port
        :return: Redis queue length
: param redis_client : Redis client : param db : Redis Database index : param port : Redis port : return : Redis queue length
def publish_queue_length(self, redis_client, port, db):
        """
        :param redis_client: Redis client
        :param db: Redis Database index
        :param port: Redis port
        :return: Redis queue length
        """
        for queue in redis_client.smembers('queues'):
            queue_length = redis_client.llen('queue:%s' % queue)
            self.__publish(port, db, queue, queue_length)
def publish_queue_length ( self , redis_client , port , db ) : for queue in redis_client . smembers ( 'queues' ) : queue_length = redis_client . llen ( 'queue:%s' % queue ) self . __publish ( port , db , queue , queue_length )