public void refreshStsOssClient()

in src/main/java/org/elasticsearch/aliyun/oss/service/OssStorageClient.java [191:210]


    public void refreshStsOssClient() throws CreateStsOssClientException {
        int retryCount = 0;
        while (isStsTokenExpired() || isTokenWillExpired()) {
            retryCount++;
            if (retryCount > REFRESH_RETRY_COUNT) {
                logger.error("Can't get valid token after retry {} times", REFRESH_RETRY_COUNT);
                throw new CreateStsOssClientException(
                    "Can't get valid token after retry " + REFRESH_RETRY_COUNT + " times");
            }
            this.client = createStsOssClient(this.metadata);
            try {
                if (isStsTokenExpired() || isTokenWillExpired()) {
                    sleep(IN_TOKEN_EXPIRED_MS * 2);
                }
            } catch (InterruptedException e) {
                logger.error("refresh sleep exception", e);
                throw new CreateStsOssClientException(e);
            }
        }
    }